问Flink Kafka连接器
EN

Stack Overflow用户

提问于 2016-05-09 13:19:43

回答 1查看 375关注 0票数 0

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

当我在IDE中将Java使用者作为独立的主程序从运行时，它工作得很好。但是当我从flink run运行它时，我看不到使用的消息，也看不到1ocalhost:8081中JobManager的stdout中的任何日志。请让我知道可能是什么问题。

发布于 2016-05-09 13:47:32

作为第一步，我建议同步版本。如果你使用的是Kafka 0.9和Flink 1.0.0，我建议你使用包含FlinkKafkaConsumer09的flink-connector-kafka-0.9版本1.0.0。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/37108176

复制

相似问题

问Flink Kafka连接器EN