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
>
