Kafka消费组删除

Kafka consumer groups deletion

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

我有两个问题

  1. Kafka支持自动删除消费者组,是否可以配置时间段删除空消费者组?
  2. 有没有具体的Kafka版本支持自动删除空Consumer组?

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

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

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