Boyang Jerry Peng created FLINK-2585: ----------------------------------------
Summary: KafkaSource not working Key: FLINK-2585 URL: https://issues.apache.org/jira/browse/FLINK-2585 Project: Flink Issue Type: Bug Reporter: Boyang Jerry Peng I tried running the KafkaConsumerExample with that is subscribing to a command line producer of kafka but the KafkaConsumerExample topology was not receiving any data from Kafka. Then I wrote my own topology that uses Kafka as a source but it didn't work as well. The topologies would run but receive not data. Can someone help me with this problem? The code I am running: -- This message was sent by Atlassian JIRA (v6.3.4#6332)