这家伙太懒,什么都没留下
向Kafka提交offset时间长于检查点间隔。 就跳过提交先前的offset,因为可以使用较新的完整检查点offset,警告可以忽视,不会影响Flink的检查点完整性。如果持续报你可以打开debug查看具体原因,一般网络问题多一点。
能详细说下么?flink无法消费到kafka中的数据
请问解决了么?我也遇到相同问题,无法解决