On May 9, 2013 5:28 AM, "Chris Curtin" <[EMAIL PROTECTED]> wrote:
It is because the consumer could be at the tail end and new data could
arrive at the server at a later time. The consumer is blocking by default
to handle a continuous stream of data.
You can find the algorithm on the design page.http://kafka.apache.org/07/design.html