Hello team,
I'm having issues understanding why my flink job commits to kafka consumer
is taking so long. I have a checkpoint of 1s and the following warning
appears. I'm currently using version 1.14.

*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*

Compared to some Kafka streams we have running, the commit latency takes
around 100 ms.
Can you point me in the right direction? Are there any metrics that I can
look at?

Best regards,

André Leite

Reply via email to