You can have two separate input operator in the same app. But you have to make sure the next operator in the dag who is taking input from these two different input operator has two input ports.
Sunil Parmar On Wed, Jul 26, 2017 at 1:18 AM, rishi <rishi.mis...@target.com> wrote: > Hi, > > I want to consume messages from two different topic(one topic on 0.8 and > another one on 0.9 ssl enabled) in one single apex application, rather then > running two different application for two different topics. > > Right now I am able to consume both topics separately . For 0.8 I am > using(KafkaSinglePortByteArrayInputOperator) and for .9 I am using > (KafkaSinglePortInputOperator) classes. > > Thanks > Rishi > > > > -- > View this message in context: http://apache-apex-users-list. > 78494.x6.nabble.com/How-to-consume-from-two-different-topics-in-one-apex- > application-tp1797.html > Sent from the Apache Apex Users list mailing list archive at Nabble.com. >
