Description
Now, DirectKafkaWordCount example is not support to visit kafka using kerberos authentication. Add Java/Scala DirectKerberizedKafkaWordCount.
Example: $ bin/run-example --files ${path}/kafka_jaas.conf \ --driver-java-options "-Djava.security.auth.login.config=${path}/kafka_jaas.conf" \ --conf "spark.executor.extraJavaOptions=-Djava.security.auth.login.config=./kafka_jaas.conf" \ streaming.DirectKerberizedKafkaWordCount broker1-host:port,broker2-host:port \ consumer-group topic1,topic2 true
Attachments
Issue Links
- links to