kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Guozhang Wang <wangg...@gmail.com>
Subject Re: consumer question
Date Fri, 23 Aug 2013 15:32:31 GMT
Hi LIbo,

Yes, this is still the case in 0.8.

Guozhang


On Fri, Aug 23, 2013 at 8:14 AM, Philip O'Toole <philip@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.yu@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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message