返回到文章

采纳

编辑于

flink消费不到kafka数据

kafka

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.