请稍等 ...
×

采纳答案成功!

向帮助你的同学说点啥吧!感谢那些助人为乐的人

开启两个springboot项目,跑的同一个flink接kafka的程序,同一个groupid,结果发现两个项目一直都在重复消费

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

插入代码

1回答

Michael_PK 2023-07-16 21:08:42

同一个groupid的不同消费者,会构成一个消费者组,他们之间不会存在重复消费呢。

你通过boot输出的日志确认下,是同一个groupid吗?

0 回复 有任何疑惑可以回复我~
  • 打了断点确认过的,的确是重复消费了,好像flink为了保证exactly-once和Kafka分组会冲突
    回复 有任何疑惑可以回复我~ 2023-07-16 21:19:03
问题已解决,确定采纳
还有疑问,暂不采纳
微信客服

购课补贴
联系客服咨询优惠详情

帮助反馈 APP下载

慕课网APP
您的移动学习伙伴

公众号

扫描二维码
关注慕课网微信公众号