我用的是 KafkaConsumer82 连接器jar版本为0.10.2，kafka版本为0.9.1，flink版本为1.0.0。当我在ide中作为独立的主程序运行java使用者时，它工作得很好。但当我把它从 flink run ，则我看不到正在使用的消息，也看不到中jobmanager的任何登录标准 1ocalhost:8081 . 请告诉我可能有什么问题。
KafkaConsumer82
flink run
1ocalhost:8081
8wtpewkr1#
作为第一步，我建议同步版本。如果你用的是Kafka 0.9 还有Flink 1.0.0 我建议使用 flink-connector-kafka-0.9 版本 1.0.0 其中包含 FlinkKafkaConsumer09 .
0.9
1.0.0
flink-connector-kafka-0.9
FlinkKafkaConsumer09
1条答案
按热度按时间8wtpewkr1#
作为第一步，我建议同步版本。如果你用的是Kafka
0.9还有Flink1.0.0我建议使用flink-connector-kafka-0.9版本1.0.0其中包含FlinkKafkaConsumer09.