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
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