[SPARK-28691] Add Java/Scala DirectKerberizedKafkaWordCount examples

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 3.0.0
• Fix Version/s: 3.0.0
• Component/s: DStreams, Examples
• Assignee: hong dongdong
• Reporter: hong dongdong
• Created: 12/Aug/19 01:27
• Updated: 12/Dec/22 18:10
• Resolved: 27/Aug/19 12:28

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

 

Issue Links

• links to: GitHub Pull Request #25412