如何从特定主题中删除 Kafka 消费者组？

Question

我更改了侦听 Kafka 主题的 Web 服务的消费者组 ID。现在，旧的组ID仍然注册到主题，但是没有具有该组ID的消费者。因此，它是滞后的。如何从特定主题中删除特定消费者组？

我试过这个：

kafka-consumer-groups --bootstrap-server kafka01.myserver.com:9092 --topic notification-topic --delete --group old-consumer-group --execute

但它返回：“消费者不支持从消费者组删除特定于主题的偏移量。 ”

我应该完全删除消费者组吗？我使用相同的组ID收听其他主题，它们会受到影响吗？

Answer 1

从 Kafka 2.4.0 开始，可以从主题中删除单个消费者组 ID 偏移量。

该调用与您已经尝试过的非常接近，但需要--delete-offsets而不是--delete：

./kafka-consumer-groups.sh \
  --bootstrap-server <bootstrap-server-url> \
  --delete-offsets \
  --group <my-group> \
  --topic <topic-name>

迄今为止，这还没有反映在官方文档中（Kafka 2.7.0 及以下版本）。然而，它在已实施并发布的改进提案KIP-496的汇合文档中进行了描述。