我以消费者的身份（最早/从一开始）在Kafka集群中消费Kafka主题（保留21天），连续15天与x消费群一起消费，第15天制作人团队停止生产，我停止消费，确认没有剩余信息可供消费。然后Kafka集群也被关闭了。然后在第16天，Kafka集群打开了，制作人在第23天启动了他的制作人，我也在myside启动了我的消费者。但当我开始的时候，我从一开始就收到了信息，而不是从我遗漏的地方收到的信息，即使我和同一个x消费群体一起消费。所以我的问题是为什么会这样？Kafka经纪人是否丢失了消费者群体的信息？
1条答案
按热度按时间e0bqpujr1#
当使用者组丢失其所有使用者时，其偏移量将保留在broker属性中配置的期间内
offsets.retention.minutes. 此属性默认为10080相当于7天-大致指消费者停止消费（第16天）和恢复消费（第23天）所用的时间。可以调整此属性以增加偏移的保留期。或者，也可以调整属性
offsets.retention.check.interval.ms这决定了检查过时偏移量的频率。