首页 文章

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

提问于
浏览
6

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

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

bin / kafka-consumer-groups.sh

--delete :警告:组删除仅适用于旧的基于ZK的使用者组,并且必须小心使用它才能删除不活动的组 .

所以我想问一下是否有办法删除通过新的消费者API创建的消费者群体?

1 回答

  • 5

    无需删除新的消费者 . 以下是脚本在尝试删除时输出的内容:

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

    这是简短的答案 . 更多细节:通过“元数据”,意味着两件事 . 首先,仅存储作为组成员协调员的一部分存储的消费者和消费者组的信息 . 如果组中的所有消费者都已消失,则会自动删除 .

    其次,消费者组已将承诺的偏移量存储在Kafka主题中(当使用新的消费者时 . 以前这些过去常常与Zookeeper一起存储) . 当消费者组消失时,不会立即删除该主题 . 如果消费者组再次出现,它将在此主题中自动找到先前的偏移量 . 它可以选择使用它们或忽略它们 . 如果消费者组永远不再出现,则这些存储的偏移量最终会自动进行垃圾回收 .

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

相关问题