Hi all,


今天发现有一个作业日志中连续打印下面这个报警

"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."


导致作业卡住无法继续消费Kafka topic


请问这个场景如何排查比较好

回复