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