如何从特定主题中删除 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

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

我应该完全删除消费者组吗？我用同一个群id听其他话题，会不会受影响？

Answer 1

您不能单独删除特定组，也不能删除组中的主题。

根据您为代理上的抵消主题定义的保留，消费者组仍然可用。滞后组未被消耗不会对性能产生影响。

注意：每次使用kafka-console-consumer，都会创建一个全新的群组。

Answer 2

从 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>

迄今为止，这并未反映在已实施和发布的 official documentation (Kafka 2.7.0 and below). However, it is described in a confluence document of improvement proposal KIP-496 中。

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

How to remove a Kafka consumer group from a specific topic?

apache-kafka

kafka-consumer-api

consumer