flink消费不到kafka数据

发表于: 2020-07-10   最后更新时间: 2020-07-13  
  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 log出错
下一条: 咨询关于kafka 配额的问题