Why does the high level consumer block, or rather where does it?

I'm trying to trace through the codebase and figure out where exactly the block occurs in the high level consumer? public void run() { ConsumerIteratorbyte[], byte[] it = m_stream.iterator(); while (it.hasNext()) System.out.println(Thread + m_threadNumber + : + new

Re: Why does the high level consumer block, or rather where does it?

Yes, ConsumerIterator blocks when there is no new message. This is done by calling take() on a blocking queue. Thanks, Jun On Sun, Jan 5, 2014 at 5:53 PM, S Ahmed sahmed1...@gmail.com wrote: I'm trying to trace through the codebase and figure out where exactly the block occurs in the high