jsmaupin
Currently, we must `gather()` all the results from a Dask stream back to the master script and then push the results to Kafka. This removes all the benefits of parallel...
This is a feature that exists in other streaming data system with windowing and aggregation functions. Its purpose is to support late arriving data in a window or aggregation. It...
It seems like the exiting PR for this needs improvements. I'm creating this issue to invite discussion on now to properly solve this problem. I would like to use the...
We are setting up Kafka in multiple data centers to achieve high availability. I expected that Streamz could do a union between both of these clusters. Everything works as expected,...