这家伙太懒,什么都没留下
程序是你写的额。你得检查了,如果有后面的消息调用了提交,就会导致之前报错的消息也跟着被提交。
手动提交模式,并没有执行提交相关方法...是怎么导致消息跳过的...
没办法的,kafka的机制如此,是按照下标来的。
可以了...取消手动提交就能拉取到数据了, 也就是在 先关闭消费者的情况下发送消息再打开,现在可以拉取到数据了... 可是这个消息跳过的问题该怎么解决, (因为项目需求用手动提交会比较好,防止丢失消息)
你把手动提交关了,换成自动提交。有可能消息跳过了。比如:10条消息,0,1,2,3,4,5,6....10。如果你提交3的偏移量,则0,1,2也认为是消费了。