我使用的是KafkaConsumer82，连接器jar版本是0.10.2，kafka版本是0.9.1，flink版本是1.0.0。
当我在IDE中将Java使用者作为一个独立的主程序从中运行时，它工作得很好。但是，当我从flink run运行它时，我看不到正在消耗的消息，也看不到1ocalhost:8081中JobManager的任何stdout日志。请告诉我可能出了什么问题。
作为第一步，我建议同步版本。如果您使用的是Kafka 0.9和Flink 1.0.0，我建议您使用包含FlinkKafkaConsumer09的flink-connector-kafka-0.9版本1.0.0。