Re: Clarification regarding multi topics implementation

2020-04-22 Thread Suresh Chidambaram
Hi Liam, Thank you very much for the suggestion. Thanks C Suresh On Thursday, April 23, 2020, Liam Clarke-Hutchinson < liam.cla...@adscale.co.nz> wrote: > Hi Suresh, > > A Topology can contain several processing workflows. So just create two > workflows in the topology builder. > > StreamsBuild

Re: Clarification regarding multi topics implementation

2020-04-22 Thread Liam Clarke-Hutchinson
Hi Suresh, A Topology can contain several processing workflows. So just create two workflows in the topology builder. StreamsBuilder sb = new StreamsBuilder(); sb.stream("sourceA")..to("sinkA"); sb.stream("sourceB")..to("sinkB"); Topology topology = sb.build(); KafkaStreams streams = KafkaStreams

Clarification regarding multi topics implementation

2020-04-22 Thread Suresh Chidambaram
Hi Team, Greetings. I have a use-case wherein I have to consume messages from multiple topics using Kafka and process it using Kafka Streams, then publish the message to multiple target topics. The example is below. Source topic A - process A - target topic A Source topic B - process B - targe