How to use in kerberized context ?

dibbhatt / kafka-spark-consumer

High Performance Kafka Connector for Spark Streaming.Supports Multi Topic Fetch, Kafka Security. Reliable offset management in Zookeeper. No Data-loss. No dependency on HDFS and WAL. In-built PID rate controller. Support Message Handler . Offset Lag checker.

Apache License 2.0

635 stars 318 forks source link

How to use in kerberized context ? #51

Closed StudioEtrange closed 6 years ago

StudioEtrange commented 7 years ago

In a context with Yarn and Kerberos where to pass this kind of options ? ` kafkaParams.put("security.protocol", "SASL_SSL"); kafkaParams.put("ssl.truststore.location","./truststore");

kafkaParams.put("ssl.truststore.password", "pass"); `

jiajf999 commented 7 years ago

同样的问题，关注

dibbhatt commented 6 years ago

Hi @StudioEtrange @jiajf999 I have made new release of the consumer 1.0.14 which now supports Kafka Security. Kindly let me know if you find any issue . ReadMe files has been updated with details ho to enable Kafka Security.

https://github.com/dibbhatt/kafka-spark-consumer#kafka-security

dibbhatt commented 6 years ago

Hi, You can see latest release. It supports the Kafka Security On Tuesday, 21 November, 2017, 10:51:54 PM GMT-5, jiajf999 notifications@github.com wrote:

同样的问题，关注

— You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub, or mute the thread.