卡夫卡消费者集团抵消保留

Question

在该组中的所有消费者失败后,kafka存储消费者的偏移量多长时间？这有配置变量吗？

Answer 1

正确的属性名称是:

offsets.retention.minutes

来自https://kafka.apache.org/documentation/#brokerconfigs

Answer 2

可以使用以下命令在kafka代理中配置该值：

offsets.retention.minutes

默认值为24小时。

请参阅： Kafka代理配置文档。