Kafka 消费者组抵消保留

Question

当一个消费者组中的所有消费者都失败后，kafka 会保存该消费者组的偏移量多长时间？ 这个有配置变量吗？

Answer 1

可以在 kafka broker 中配置该值，使用：

offsets.retention.minutes

默认值为 24 小时。

参见： Kafka 代理配置 docs。

Answer 2

正确的属性名字是：

offsets.retention.minutes

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

Answer 3

我在 Kafka 配置中添加了以下 属性， 它将偏移保留时间更改为 7 天，效果很好。

offsets.retention.minutes=10080