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
