Hi Rishi, You can use KafkaSinglePortInputOperator which is under malhar-kafka010 module. Set the SSL properties to the "consumerProps" parameter as below:
KafkaSinglePortInputOperator input = dag.addOperator("InputFromKafka", new KafkaSinglePortInputOperator()); Properties prop = new Properties(); // Set the ssl properties to "prop" input.setConsumerProps(prop); Regards, Chaitanya On Mon, Jul 3, 2017 at 4:43 PM, rishi <rishi.mis...@target.com> wrote: > Hi, > > Is there any built in operator in Apex which I can use to consume message > from kafka topic [ which is SSL enabled and version 10]. > > Thanks > Rishi > > > > -- > View this message in context: http://apache-apex-users-list. > 78494.x6.nabble.com/How-to-consume-from-Kafka-V10-SSL- > enabled-topic-using-Apex-tp1773.html > Sent from the Apache Apex Users list mailing list archive at Nabble.com. > -- *Chaitanya* Software Engineer E: chaita...@datatorrent.com | Twitter: @chaithu1403 www.datatorrent.com | apex.apache.org