返回到文章

采纳

编辑于 4年前

flink消费不到kafka数据

kafka

  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.