Update DirectKerberizedKafkaWordCount.scala

apache · Aug 14, 2019 · 75f9ab8 · 75f9ab8
1 parent 5c958c1
commit 75f9ab8
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/...s/src/main/scala/org/apache/spark/examples/streaming/DirectKerberizedKafkaWordCount.scala b/...s/src/main/scala/org/apache/spark/examples/streaming/DirectKerberizedKafkaWordCount.scala
@@ -41,6 +41,17 @@ import org.apache.spark.streaming.kafka010._
  *    "spark.executor.extraJavaOptions=-Djava.security.auth.login.config=./kafka_jaas.conf" \
  *    streaming.DirectKerberizedKafkaWordCount broker1-host:port,broker2-host:port \
  *    consumer-group topic1,topic2
+ *
+ * kafka_jaas.conf can manually create, template as:
+ *   KafkaClient {
+ *     com.sun.security.auth.module.Krb5LoginModule required
+ *     keyTab="${path_of_keytab}/kafka.service.keytab"
+ *     useKeyTab=true
+ *     storeKey=true
+ *     useTicketCache=false
+ *     serviceName="kafka"
+ *     principal="kafka/server@example";
+ *   };
  */
 object DirectKerberizedKafkaWordCount {
   def main(args: Array[String]) {