apache-kafka - Zookeeper和Kafka服务器重启后Kafka消费组依然存在

Question

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

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

任何人都可以向我澄清这一点吗？

标签： apache-kafkaapache-zookeeper

Answer 1

从 Kafka 0.9 开始，Consumer Offsets 直接存储在 Kafka 的内部主题中，称为__consumer_offsets.

消费者偏移量在重新启动后保留，并且至少保留offsets.retention.minutes（默认情况下为 7 天）。

如果要重置消费者组，您可以：

• 使用kafka-consumer-groups.sh带有--reset-offsets选项的工具

• 使用AdminClient.deleteConsumerGroups()完全删除消费者组