重启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 天)。

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