采纳答案成功!
向帮助你的同学说点啥吧!感谢那些助人为乐的人
同一个groupid的不同消费者,会构成一个消费者组,他们之间不会存在重复消费呢。
你通过boot输出的日志确认下,是同一个groupid吗?
打了断点确认过的,的确是重复消费了,好像flink为了保证exactly-once和Kafka分组会冲突
登录后可查看更多问答,登录/注册
已经在做大数据,Flink助力轻松提薪;尚未入行,让你弯道超车
968 9
811 7
567 6
516 6
789 5