【问题标题】:Kafka consumer groups still exists after the zookeeper and Kafka servers are restartedZookeeper和Kafka服务器重启后Kafka消费组依然存在
【发布时间】:2019-12-22 13:30:26
【问题描述】:

我将 Zookeeper 和 Kafka 用于使用 Java 的消息传递用例。我认为当您重新启动 Zookeeper 和 Kafka 服务器时,消费者组的详细信息将被删除。但他们没有。 Zookeeper 是否将消费者组的详细信息保存在某种文件中?

如果我想重置消费者组,是否应该手动删除消费者组详细信息?

谁能给我澄清一下?

【问题讨论】:

    标签: apache-kafka apache-zookeeper


    【解决方案1】:

    从 Kafka 0.9 开始,Consumer Offsets 直接存储在 Kafka 的一个名为 __consumer_offsets 的内部主题中。

    Consumer Offsets 会在重启后保留,并至少保留 offsets.retention.minutes(默认为 7 天)。

    如果您想重置消费者组,您可以:

    【讨论】:

      猜你喜欢
      • 2018-10-31
      • 2019-12-06
      • 2017-10-30
      • 2015-08-08
      • 1970-01-01
      • 2015-05-28
      • 2019-02-10
      • 2017-11-20
      • 1970-01-01
      相关资源
      最近更新 更多