flink消费不到kafka数据

悟 发表于: 2020-07-10   最后更新时间: 2020-07-13 15:50:10   2,314 游览

  1. flink消费不到kafka数据

  2. 一个服务器上有kafka集群，一直在生产数据，消费数据的程序在另一个服务器，但是一直消费不到，两个服务器能ping通，用的flink消费，端口也能telnet通

  3. 以下日志一直循环打印

    20/07/10 04:17:21 INFO checkpoint.CheckpointCoordinator: Completed checkpoint 20 for job a205b888f33a760b54917c4376f1fd74 (9087 bytes in 5 ms).
20/07/10 04:17:21 WARN 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相关的其他问题或提一个您自己的问题。
提问

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