重启zookeeper和kafka服务器后,kafka消费组仍然存在
Kafka consumer groups still exists after the zookeeper and Kafka servers are restarted
我将 Zookeeper 和 Kafka 用于使用 Java 的消息传递用例。我认为当您重新启动 Zookeeper 和 Kafka 服务器时,消费者组的详细信息将被删除。但他们没有。 zookeeper 是否将消费者组的详细信息保存在某种文件中?
如果我想重置消费者组,是否应该手动删除消费者组详细信息?
谁能给我解释一下?
从 Kafka 0.9 开始,Consumer Offsets 直接存储在 Kafka 中一个名为 __consumer_offsets
的内部主题中。
Consumer Offsets 在重启后保留,并且至少保留 offsets.retention.minutes
(默认为 7 天)。
如果你想重置消费者组,你可以:
使用带有 --reset-offsets
选项的 kafka-consumer-groups.sh
工具
使用AdminClient.deleteConsumerGroups()完全删除消费者组
我将 Zookeeper 和 Kafka 用于使用 Java 的消息传递用例。我认为当您重新启动 Zookeeper 和 Kafka 服务器时,消费者组的详细信息将被删除。但他们没有。 zookeeper 是否将消费者组的详细信息保存在某种文件中?
如果我想重置消费者组,是否应该手动删除消费者组详细信息?
谁能给我解释一下?
从 Kafka 0.9 开始,Consumer Offsets 直接存储在 Kafka 中一个名为 __consumer_offsets
的内部主题中。
Consumer Offsets 在重启后保留,并且至少保留 offsets.retention.minutes
(默认为 7 天)。
如果你想重置消费者组,你可以:
使用带有
--reset-offsets
选项的kafka-consumer-groups.sh
工具使用AdminClient.deleteConsumerGroups()完全删除消费者组