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/

Reply via email to