Hi all,
 
我这变flink任务日志发现,一直在报一个 告警,告警内容是:
   
 ```
  2021-04-21 09:13:07,218 WARN 
org.apache.flink.streaming.connectors.kafka.internal.KafkaFetcher [] - 
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遇到问题,请问下,大家有谁遇到过这个问题么,如何排查,烦请给些建议,万分感谢


guoxb__...@sina.com

回复