♂裝純男た

只要提交offset过期时间就会重新计时。以下转载自 https://www.jianshu.com/p/5a7249df82a8 ： consumer的commit offset保存在broker集群的有50个partition的内部topic里，保存时间 offsets.retention.minutes (1440 minutes = 1 day) 的意思是说超过这个时间没有再次commit就删除该consumer的commit offfset，意义在于删除长期离线的consumer的commit信息。如果consumer从broker取commit时，还没有提交过offset或是已经被删除，就返回0。

已解决，找到的问题在上个评论。

如果数据已过期，是无法再重置到其偏移量再进行消费的。server配置的数据和位移保留时间分别为多少？两个消费者的配置一样吗？我觉得需要具体查看下对应的位移信息才能确定。

我查看了一下没有消费到数据是因为测试环境的数据只保留了1个小时，但是本地消费程序可以将当前偏移量指向末尾，但是项目上的消费者就不行。本地和项目中的消费者属于同一个消费组

使用命令./kafka-consumer-groups.sh --bootstrap-server localhost:9094 --describe --group group-name可查看对应的位移信息，如过期则显示横杆。我没使用过程序去重置偏移量，直接使用命令重置可正常消费。重置后从修改之前的地方消费具体是到哪个位置？本地编写的消费程序与前面提及消费者是属于同一个消费组的吗？