On 5/9/13 8:27 AM, Chris Curtin wrote:
The iterator will block if there is no more data to consume. The
iterator is actually reading messages from a BlockingQueue which is fed
messages by the fetcher threads. The reason for this is to allow you to
configure blocking with or without a timeout in the ConsumerIterator.
This is reflected in the consumer timeout property (consumer.timeout.ms)
Down at the bottom of the 0.7 design page http://kafka.apache.org/07/design.html