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.
>
> StreamsBuilder sb = new StreamsBuilder();
> sb.stream("sourceA").<do A stuff>.to("sinkA");
> sb.stream("sourceB").<do B stuff>.to("sinkB");
> Topology topology = sb.build();
> KafkaStreams streams = KafkaStreams(topology, streamsConfig);
> streams.start();
>
> Hope that helps,
>
> Liam Clarke-Hutchinson
>
> On Thu, 23 Apr. 2020, 4:41 am Suresh Chidambaram, <chida.sur...@gmail.com>
> wrote:
>
> > 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 - target topic B
> >
> > Could someone help me achieving this solution?
> >
> > I have to use Spring Boot with Kafka Streams for this solution.
> >
> > Thank you.
> > C Suresh
> >
>
