Hi, I just installed the kafka 0.9, and my code stuck on the following command
for producer: it is stuck on producer.flush(); for consume, it is stuck on ConsumerRecords<String, String> records = consumer.poll(200); I did directly downloaded the code from github, and tried some other resources for 0.9, nothing is working. https://github.com/mapr-demos/kafka-sample-programs Have configured all the parameter from the *.props files. Thanks Jacky
