如何删除Kafka消费群(通过新的消费者API创建)？ [英] How to delete kafka consumer group (created via new consumer api)?

问题描述

我通过新的消费者接口创建了Kafka消费者
我使用的是卡夫卡2.10-0.9.0.1
我们有一个消费者组，每个组中有一个消费者实例

Kafka脚本‘kafka-Consumer-groups.sh’提供了删除用户的方法，但这仅适用于旧的消费群体 正在运行命令：

bin/kafka-Consumer-groups.sh

给予

--删除：警告：组删除仅适用于基于ZK的旧消费组，必须谨慎使用，以便仅删除非活动的组。

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

推荐答案

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

请注意，没有必要删除新使用者的组元数据，因为它会在最后一个成员离开时自动删除

这是简短的答案。更多细节："元数据"指的是两件事。首先，只是作为组成员资格协调器的一部分存储的关于消费者和消费者组的信息。如果组中的所有使用者都消失，则会自动删除。

其次，消费者组已将承诺的偏移量存储在Kafka主题中(当使用新的消费者时。以前，这些文件通常与ZooKeeper一起存储)。当消费者组消失时，该主题不会立即删除。如果消费者组再次出现，它将在本主题中自动查找以前的偏移量。它可以选择使用它们，也可以忽略它们。如果使用者组再也不出现，这些存储的偏移量最终将被自动垃圾收集。

因此，简而言之，在使用新的使用者时不需要删除任何内容。

这篇关于如何删除Kafka消费群(通过新的消费者API创建)？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！