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 <chaita...@datatorrent.com
> wrote:
> 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-enable
>> d-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
>
>
>
