Flink Kafka連接器

Question

我使用的是KafkaConsumer82，連接器jar版本是0.10.2，kafka版本是0.9.1，flink版本是1.0.0。

當我在IDE中作爲獨立主程序運行它時，Java使用者正常工作。但是當我從flink run運行它時，我看不到消息被消耗，並且在1ocalhost:8081中看不到JobManager的標準輸出中的任何日誌。請讓我知道可能是什麼問題。

Answer 1

作爲第一步，我會建議讓版本同步。如果您使用的是卡夫卡0.9和Flink 1.0.0我建議使用flink-connector-kafka-0.9版本1.0.0其中包含FlinkKafkaConsumer09。