Looking forward to dive deep in most optimal design strategy for Kafka topic migration.
I am publishing to two topics. Topic-1(legacy) topic-2 (new topic)
I want my consumer to migrate to new topic topic-2. How to do this migration with no consumer downtime and no loss of data.
Topic 1 and topic-2 are not guaranteed to be in sync and publish at same time , will have same data flow though.

Good Day.
I am trying to implement sync request reply message flow using ReplyingKafkaTemplate. It worked fine as a individual POC. But my application has already kafka implementation to consume the messages manually. I am using ConcurrentMessageListenerContainer as shown below.