如何管理 Kafka 组的过期答案

【问题标题】：How to manage expiration of Kafka Groups如何管理 Kafka 组的过期
【发布时间】：2017-08-04 21:53:01
【问题描述】：

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

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.

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

【问题讨论】：

标签： stream apache-kafka offset

【解决方案1】：

该配置实际上是一个代理配置，用于确定将提交的偏移量保持多长时间：offsets.retention.minutes。您可能还想根据您选择的保留值调整offsets.retention.check.interval.ms。 (reference)

【讨论】：

默认值为 1440 分钟，即 24 小时/1 天