Re: best way to duplicate a KStream?

great, thanks again! On Thu, Apr 14, 2016 at 12:07 PM, Guozhang Wang wrote: > Hi Greg, > > You can apply multiple operations on the same streams object in the Kafka > Streams DSL, for example: > > stream1 = builder.stream("topic1"); > > stream2 = stream1.map(/*set

Re: best way to duplicate a KStream?

Hi Greg, You can apply multiple operations on the same streams object in the Kafka Streams DSL, for example: stream1 = builder.stream("topic1"); stream2 = stream1.map(/*set key*/).through("topic2").aggregateByKey(...); stream3 = stream1.map(/*a different

best way to duplicate a KStream?

Hi all, I'm working on a Kafka Streaming job and I've hit a case I didn't see straightforward support for. I have an input stream topic I'd like to perform two separate aggregations on, but building up two parallel sub-topologies with the same source topic at the source results in an error: "Topic