Without looking at your complete code, I'm only going to make some guesses.
Unless you really want to shutdown the consumer, why would you call
consumer.shutdown()? A consumer will keep waiting for new messages unless
otherwise specified.
I'm guessing you used something like while iterator.hasNex
Hi,
I just started with Apache Kafka and wrote a high level consumer program
following the example given here
https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example.
Though, I was able to run the program and consume the messages, I have one
doubt regarding *consumer.shutdown()*.
