Hello, I saw this thread <http://mail-archives.apache.org/mod_mbox/kafka-users/201307.mbox/%3CCAFbh0Q1k4MtzF-QityyxGrb6Dy=gjghw-0y9t8dmjnv2ghp...@mail.gmail.com%3E> and have the opposite problem. I am using the code here <https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example> and find that my consumer breaks out of this while loop when the message log is empty: while (it.hasNext()) System.out.println("Thread " + m_threadNumber + ": " + new String(it.next().message())); my consumerTimeoutMs is equal to -1. Isn’t that supposed to make the iterator blocking, meaning it should never break out of the while loop? TIA
