nik*_*610 6 java web-services apache-kafka spring-boot kafka-consumer-api
我通过新的消费者API创建了kafka消费者
我正在使用kafka 2.10-0.9.0.1
我们有1个消费者群体,每个群体中有1个消费者实例
Kafka脚本'kafka-consumer-groups.sh'提供了删除用户的方法,但这仅适用于旧的使用者组运行命令:
给
--delete:警告:组删除仅适用于旧的基于ZK的使用者组,并且必须小心使用它才能删除不活动的组.
所以我想问一下是否有办法删除通过新的消费者API创建的消费者群组？
无需删除新的消费者.以下是脚本在尝试删除时输出的内容:
请注意,不需要删除新使用者的组元数据,因为它会在最后一个成员离开时自动删除
这是简短的答案.更多细节:通过"元数据",意味着两件事.首先,仅存储作为组成员协调员的一部分存储的消费者和消费者组的信息.如果组中的所有消费者都已消失,则会自动删除.
其次,消费群体已经存储了卡夫卡主题中的承诺偏移(当使用新的消费者.以前这些用于存储与动物园管理员).当消费者组消失时,不会立即删除该主题.如果消费者组再次出现,它将在此主题中自动找到先前的偏移量.它可以选择使用它们或忽略它们.如果消费者组永远不再出现,则这些存储的偏移量最终会自动进行垃圾回收.
简而言之,在使用新消费者时无需删除任何内容.
| 归档时间： |
|
| 查看次数： |
6039 次 |
| 最近记录： |