kafka消费者手动提交问题

kafka消费者手动提交问题

消费者设置手动提交后,之前poll到但是未提交的消息消费不重启项目消费不到,这个有什么好的解决方案么。看了下comsumer会记录一个消费的offset,这个offset提交的和未提交的都会记录,这样导致客户端的offset比服务器端kafka的offset位置提前,所以拉取不到。

正在回答 回答被采纳积分+1

登陆购买课程后可参与讨论,去登陆

1回答
阿神 2021-07-02 15:38:25

没理解呢,手工提交是一个一个提交的,也就多是一个消息处理完了后,再提交。consumer是单线程的哦

  • 提问者 小蝴蝶噼里啪啦 #1

    就是kafka设置手动提交后,我消费到这条消息,但是不给他提交,在不重启项目的情况下是不是这条消息也不会被再次消费到。

    2021-07-21 14:03:27
问题已解决,确定采纳
还有疑问,暂不采纳

恭喜解决一个难题,获得1积分~

来为老师/同学的回答评分吧

0 星
请稍等 ...
意见反馈 帮助中心 APP下载
官方微信

在线咨询

领取优惠

免费试听

领取大纲

扫描二维码,添加
你的专属老师