请稍等 ...
×

采纳答案成功!

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

开启两个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下载
官方微信