我对apachekafka还不熟悉，我正在尝试使用某个主题的消息。我从控制台运行以下命令以查看消息：
bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --from-beginning
但在那之后，我可以看到一个名为“console-consumer-4158”的使用者被创建，我意外地关闭了控制台。
如何终止正在运行的消费者？
我对apachekafka还不熟悉，我正在尝试使用某个主题的消息。我从控制台运行以下命令以查看消息：
bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --from-beginning
但在那之后，我可以看到一个名为“console-consumer-4158”的使用者被创建，我意外地关闭了控制台。
如何终止正在运行的消费者？
1条答案
按热度按时间1sbrub3j1#
终止使用者后，进程本身将停止。
当您使用旧的使用者api时，groupid（console-consumer-4158）+关于消耗的偏移量的信息存储在zookeeper中。没有自动删除未使用组的进程（请参阅更多）