java - 如何删除kafka消费者组(通过新的消费者api创建)？

Question

我已经通过新的消费者 API 创建了 kafka 消费者
我正在使用 kafka 2.10-0.9.0.1
我们有 1 个消费者组，每个组中有 1 个消费者实例

Kafka 脚本 'kafka-consumer-groups.sh' 提供了删除用户的方法，但这只适用于旧的消费者组运行命令:

bin/kafka-consumer-groups.sh

给予

--delete:警告:组删除仅适用于旧的基于 ZK 的消费者组，必须谨慎使用它以仅删除不活动的组。

所以我想问一下有什么方法可以删除通过新的消费者API创建的消费者组吗？

Answer 1

不需要用新的消费者删除。以下是尝试删除时脚本的输出:

Note that there's no need to delete group metadata for the new consumer as it is automatically deleted when the last member leaves

这是简短的回答。更多细节:“元数据”有两层含义。首先，只是作为组成员协调器的一部分存储的有关消费者和消费者组的信息。如果组中的所有消费者都消失了，它会自动删除。

其次，消费者组已将提交的偏移量存储在 Kafka 主题中(当使用新消费者时。以前这些用于存储在 Zookeeper 中)。当消费者组消失时，该主题不会立即删除。如果消费者组再次出现，它会自动在这个主题中找到之前的偏移量。它可以选择使用它们或忽略它们。如果消费者组不再出现，这些存储的偏移量最终会被自动垃圾回收。

所以简而言之，使用新消费者时不需要删除任何东西。