Hi LIbo, Yes, this is still the case in 0.8.
Guozhang On Fri, Aug 23, 2013 at 8:14 AM, Philip O'Toole <phi...@loggly.com> wrote: > Yes, the Kafka team has told me that this is how it works (at least for > 0.72). > > Philip > > On Fri, Aug 23, 2013 at 7:53 AM, Yu, Libo <libo...@citi.com> wrote: > > Hi team, > > > > Right now, from a stream, an iterator can be obtained which has a > blocking hasNext(). > > So what is the implementation behind the iterator? I assume there must > be queue and > > the iterator monitors the queue. And a separate thread fetches data and > feeds to the > > queue when it is almost empty. If that is the case, no more optimization > needs to be > > done by our users. Please confirm if there is a separate thread that > fetches data and > > feeds to the queue. Thanks. > > > > > > Regards, > > > > Libo > > > -- -- Guozhang
