You can take a look at the source code of MirrorMaker.scala, which uses the wildcard api createMessageStreamsByFilter().
Thanks, Jun On Wed, May 7, 2014 at 6:05 AM, Kannadhasan Sekar <thasan...@gmail.com>wrote: > Hi Guozhang Wang <http://qnalist.com/user/guozhang-wang/> & Neha > Narkhede<http://qnalist.com/user/neha-narkhede/> > , > > Thanks for your answers for this question > http://qnalist.com/questions/4846254/kafka-dynamic-topic-discovery .I > tried > high level consumer in the following example > > https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example< > https://kafka.apache.org/documentation.html#highlevelconsumerapi> > > But it is consuming data in a single topic which given number of thread > concurrently. > > I don't know how to use wild card consumption which is given available High > level Consumer API. > How to get topic/message because I have to authenticate under this topic > this is the message > > Thanks > , > Kannadhasan s >
