Re: Kafka Streams demultiplexer

2016-04-16 Thread Guozhang Wang
Hi Ben, Have you checked the "branch" function of KStream, and see if that fits your needs? It requires all the generated streams share the same data types, but it seems to be the case for your scenario. Guozhang On Sat, Apr 16, 2016 at 7:31 AM, Benjamin Manns wrote: > Hi all, > > I'm taking

Kafka Streams demultiplexer

2016-04-16 Thread Benjamin Manns
Hi all, I'm taking a look at the new Kafka Streams system in 0.10, and I was wondering if anyone has an example or knows how I might demultiplex a topic with Kafka Streams. It looks pretty easy to join streams together (which is great), but I only see ways to produce a single (or a predetermined n