如何管理卡夫卡組的過期

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，具體取決於您選擇的保留值。 （reference）