在一个消费群体中的所有消费者都失败之后，Kafka存储该消费群体的补偿多长时间？这个有配置变量吗？
z0qdvdin1#
我在kafka配置中添加了以下属性，它将偏移保留时间改为7天，并且工作良好。offset.retention.minutes=10080分钟
llycmphe2#
可使用以下方法在kafka broker中配置该值：
offsets.retention.minutes
默认值为 24 小时。参见：Kafka经纪人配置文件。
24
9rbhqvlz3#
正确的属性名称是：
从https://kafka.apache.org/documentation/#brokerconfigs
3条答案
按热度按时间z0qdvdin1#
我在kafka配置中添加了以下属性，它将偏移保留时间改为7天，并且工作良好。
offset.retention.minutes=10080分钟
llycmphe2#
可使用以下方法在kafka broker中配置该值：
默认值为
24小时。参见：Kafka经纪人配置文件。
9rbhqvlz3#
正确的属性名称是：
从https://kafka.apache.org/documentation/#brokerconfigs