kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Yu, Libo " <libo...@citi.com>
Subject consumer question
Date Fri, 23 Aug 2013 14:53:55 GMT
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.



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