如何管理 Kafka 组的过期

Question

我试图通过删除消费者配置并让我的脚本稍后重新创建它来重置消费者配置，但我遇到了关于新消费者不可删除的错误。

kafka@kafka-0:~$ ./bin/kafka-consumer-groups.sh --bootstrap kafka-0:9092 --delete --group etl
Option '[delete]' is only valid with '[zookeeper]'. Note that there's no need to delete group metadata for the new consumer as the group is deleted when the last committed offset for that group expires.

现在我想知道，控制此错误消息过期的消费者配置选项的名称是什么？

Answer 1

该配置实际上是一个代理配置，用于确定将提交的偏移量保留多长时间：offsets.retention.minutes。您可能还需要offsets.retention.check.interval.ms根据您选择的保留值进行调整。（参考）