You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@apex.apache.org by rishi <ri...@target.com> on 2017/07/03 11:13:09 UTC
How to consume from Kafka-V10 (SSL enabled) topic using Apex
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.
Re: How to consume from Kafka-V10 (SSL enabled) topic using Apex
Posted by Thomas Weise <th...@apache.org>.
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 <chaitanya@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 <ri...@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: chaitanya@datatorrent.com | Twitter: @chaithu1403
>
> www.datatorrent.com | apex.apache.org
>
>
>
Re: How to consume from Kafka-V10 (SSL enabled) topic using Apex
Posted by Chaitanya Chebolu <ch...@datatorrent.com>.
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 <ri...@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: chaitanya@datatorrent.com | Twitter: @chaithu1403
www.datatorrent.com | apex.apache.org