如何管理卡夫卡组的过期

Question

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

[email protected]:~$ ./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，具体取决于您选择的保留值。 （reference）