Yes, see consumer.timeout.ms in http://kafka.apache.org/configuration.html

Thanks,

Jun

On Sun, Jan 20, 2013 at 7:14 PM, Ryan LeCompte <lecom...@gmail.com> 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

Reply via email to