flink消费不到kafka数据

小龟快跑哦 发表于: 2020-03-10   最后更新时间: 2020-03-10 20:24:08   5,551 游览

Flink 版本 1.6.1
kafka 版本 0.10

flink输出该警告后不能消费数据

2019-07-18 10:13:51,908 WARN org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher - 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
发表于 2020-03-10
小龟快跑哦
添加评论

向Kafka提交offset时间长于检查点间隔。 就跳过提交先前的offset，因为可以使用较新的完整检查点offset，警告可以忽视，不会影响Flink的检查点完整性。
如果持续报你可以打开debug查看具体原因，一般网络问题多一点。

回复
回答于 4年前
半兽人
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。