Hi Sachin; I went through the KStream/KTable Documentation. My scenario is very simple..I want to merge two topics( ie: Send messages available in the topic A -->topic B , in my case i'll be having only single message in that topicA)
Do I need Stateful processing (KStream)? Thanks. On 10 October 2016 at 13:10, Ratha v <vijayara...@gmail.com> wrote: > Thank you.I'll try the solution. > But in the highlevel consumer API, topics will be created automatically? , > We are not using zookeeper? > > On 10 October 2016 at 12:34, Sachin Mittal <sjmit...@gmail.com> wrote: > >> 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/ >> > > > > -- > -Ratha > http://vvratha.blogspot.com/ > -- -Ratha http://vvratha.blogspot.com/
