如何删除kafka消费者组(通过新消费者api创建)?

2023-12-24

我通过新的消费者 API 创建了 kafka 消费者
我使用的是卡夫卡2.10-0.9.0.1
我们有 1 个消费者组,每组有 1 个消费者实例

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

bin/kafka-consumer-groups.sh

Gives

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

所以我想问有没有办法删除通过新消费者API创建的消费者组?


不需要用新的consumer来删除。以下是尝试删除时脚本输出的内容:

请注意,无需删除新消费者的组元数据,因为当最后一个成员离开时它会自动删除

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

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

所以简而言之,使用新消费者时无需删除任何内容。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如何删除kafka消费者组(通过新消费者api创建)? 的相关文章

随机推荐