【发布时间】:2019-12-22 13:30:26
【问题描述】:
我将 Zookeeper 和 Kafka 用于使用 Java 的消息传递用例。我认为当您重新启动 Zookeeper 和 Kafka 服务器时,消费者组的详细信息将被删除。但他们没有。 Zookeeper 是否将消费者组的详细信息保存在某种文件中?
如果我想重置消费者组,是否应该手动删除消费者组详细信息?
谁能给我澄清一下?
【问题讨论】:
标签: apache-kafka apache-zookeeper
我将 Zookeeper 和 Kafka 用于使用 Java 的消息传递用例。我认为当您重新启动 Zookeeper 和 Kafka 服务器时,消费者组的详细信息将被删除。但他们没有。 Zookeeper 是否将消费者组的详细信息保存在某种文件中?
如果我想重置消费者组,是否应该手动删除消费者组详细信息?
谁能给我澄清一下?
【问题讨论】:
标签: apache-kafka apache-zookeeper
从 Kafka 0.9 开始,Consumer Offsets 直接存储在 Kafka 的一个名为 __consumer_offsets 的内部主题中。
Consumer Offsets 会在重启后保留,并至少保留 offsets.retention.minutes(默认为 7 天)。
如果您想重置消费者组,您可以:
将kafka-consumer-groups.sh 工具与--reset-offsets 选项一起使用
使用AdminClient.deleteConsumerGroups()完全删除Consumer组
【讨论】: