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