You can use topicA.leftJoin (topicB).to (new-topic). You can the consume message from that new topic via second process. Note you need to create all three topics in zookeeper first.
On 10 Oct 2016 5:19 a.m., "Ratha v" <vijayara...@gmail.com> wrote: Hi all; I have two topics in the broker. Without consuming from one topic, I want to merge both topics, and will consume messages from the second topic. It is because, I have two processes, one process, pushes messages to topic A. And the second process once finished processing, it wants to merge both topicA and TopicB. Then another process will consume messages from the merged topic. How can I merge both topics in high level kafka APIs. I use Kafka 0.10.0.1. Thanks. -- -Ratha http://vvratha.blogspot.com/