Hi Team, I'm running into strange issue pasted below:
Committing offsets to Kafka takes longer than the checkpoint interval. Skipping commit of previous offsets because newer complete checkpoint offsets are available. This does not compromise Flink's checkpoint integrity. I read data from more than 10 different Kafka topics, I started noticing this issue as I integrate more number of Kafkaconsumer reading from respective topics. Wondering if there is any upper limit on the number of Kafka consumers (Kafka topics) per job? If not could someone please shed some light on why this could be happening? Thanks, RK
