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

来源：11-3 Flink整合Kafka代码开发

weixin_慕码人4150737

2023-07-15

写回答

1回答

Michael_PK

2023-07-16

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

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

weixin_慕码人4150737

打了断点确认过的，的确是重复消费了，好像flink为了保证exactly-once和Kafka分组会冲突

2023-07-16

共1条回复

Flink+ClickHouse 玩转企业级实时大数据开发

已经在做大数据，Flink助力轻松提薪；尚未入行，让你弯道超车

1000 学习 · 225 问题

相似问题

回答 2

回答 2

回答 1

回答 1

回答 1