Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Non-blocking Kafka stream iterators

Copy link to this message
Re: Non-blocking Kafka stream iterators
Yes, see consumer.timeout.ms in http://kafka.apache.org/configuration.html



On Sun, Jan 20, 2013 at 7:14 PM, Ryan LeCompte <[EMAIL PROTECTED]> wrote:

> Hello all,
> Does Kafka still only support blocking stream iterstors? It would be great
> to pass a timeout or have a poll() operation for fetching items. Right now
> I'm always blocking in this call:
> for (m <- stream) ...
> Thanks!
> Ryan