Kafka消费者组删除

Vin*_* NG 4 apache-kafka kafka-consumer-api

我在 Kafka 中创建了大量的消费者组。当我检查状态时,大多数状态为空,没有活跃的消费者。

我有两个问题

  1. Kafka支持自动删除消费者组,是否可以配置一个时间段来删除空的消费者组?
  2. 是否有特定的 Kafka 版本支持自动删除空 Consumer 组?

Mic*_*son 7

要删除空的消费者组,您有 2 个选项:

  • 什么也不做,等待offsets.retention.minutes。此设置默认为 7 天。在此期间没有任何成员的组将被自动删除。这个机制从Kafka 0.8.2就存在了!

  • 使用删除消费者组API。deleteConsumerGroups这可以通过管理 API 的方法或 脚本来使用kafka-consumer-groups.sh。该 API 自 Kafka 1.1 起就存在。