Vin*_* NG 4 apache-kafka kafka-consumer-api
我在 Kafka 中创建了大量的消费者组。当我检查状态时,大多数状态为空,没有活跃的消费者。
我有两个问题
要删除空的消费者组,您有 2 个选项:
什么也不做,等待offsets.retention.minutes。此设置默认为 7 天。在此期间没有任何成员的组将被自动删除。这个机制从Kafka 0.8.2就存在了!
使用删除消费者组API。deleteConsumerGroups这可以通过管理 API 的方法或 脚本来使用kafka-consumer-groups.sh。该 API 自 Kafka 1.1 起就存在。
| 归档时间: |
|
| 查看次数: |
2329 次 |
| 最近记录: |