[1]搭建集群

[2]測試kafka集群沒問題后,

根據[3]中開始用flink消費kafka數據,發現啥也么有

調試辦法如下:

①去$KAFKA/logs下面看了下,是有相關主題的文件夾生成的.

② /kafka-console-consumer.sh --bootstrap-server Desktop:9091,Laptop:9092,Laptop:9093 --topic test-0921

依然沒有數據

③./kafka-console-consumer.sh --bootstrap-server Desktop:9091,Laptop:9092,Laptop:9093 --topic test-0921 --from-beginning

出來一大堆數據,以此判定kafka集群的數據生成是沒啥問題的.

④加入

props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");

代碼結束處刪除

keyedStream.writeAsText("/home/appleyuchi/KafkaFlinkTest");

 

終于有數據輸出了．　

⑤

總結

以上是生活随笔為你收集整理的flink读不到kafka数据问题的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。