Re: How to consume from Kafka-V10 (SSL enabled) topic using Apex

You can use the operators that work with 0.9 Kafka client to access 0.10 Kafka cluster (Malhar release 3.7 has only operators that work with 0.9 client, next release will have 0.10 client support). Thomas On Mon, Jul 3, 2017 at 4:52 AM, Chaitanya Chebolu wrote: > Hi

Re: How to consume from Kafka-V10 (SSL enabled) topic using Apex

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