【问题标题】:Apache Kafka Consumer - terminate from consoleApache Kafka Consumer - 从控制台终止
【发布时间】:2017-07-20 01:39:10
【问题描述】:

我是 Apache Kafka 的新手,我正在尝试使用来自某个主题的消息。我从控制台运行以下命令来查看消息:

bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic test --from-beginning

但在那之后我可以看到一个名为“console-consumer-4158”的消费者正在创建,我不小心关闭了控制台。

如何终止正在运行的消费者?

【问题讨论】:

    标签: java apache-kafka kafka-consumer-api apache-kafka-connect


    【解决方案1】:
    1. 终止消费者后,进程本身将停止。
    2. 当您使用旧的消费者 API 时,groupId (console-consumer-4158) + 有关已消费偏移量的信息存储在 zookeeper 中。没有自动删除未使用组的进程 (see more)

    【讨论】:

    • 这是我的问题。消费者将如何被终止或如何从我们这里终止?
    • 控制台消费者是一个简单的java进程。如果你关闭控制台,进程将被自动杀死
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2017-10-23
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多