如何管理Kafka组的过期

ctzwtxfj  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(501)

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

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.

现在我想知道,控制此错误消息过期的consumer config选项的名称是什么?

neskvpey

neskvpey1#

该配置实际上是一个代理配置,用于确定将提交的偏移保持在以下位置的时间: offsets.retention.minutes . 您可能还需要调整 offsets.retention.check.interval.ms 取决于您选择的保留值((参考)

相关问题