vanzin commented on a change in pull request #25631: [SPARK-28928][SS]Use Kafka 
delegation token protocol on sources/sinks
URL: https://github.com/apache/spark/pull/25631#discussion_r321918536
 
 

 ##########
 File path: docs/structured-streaming-kafka-integration.md
 ##########
 @@ -770,7 +770,9 @@ Delegation tokens can be obtained from multiple clusters 
and <code>${cluster}</c
     <td><code>spark.kafka.clusters.${cluster}.security.protocol</code></td>
     <td>SASL_SSL</td>
     <td>
-      Protocol used to communicate with brokers. For further details please 
see Kafka documentation. Only used to obtain delegation token.
+      Protocol used to communicate with brokers. For further details please 
see Kafka documentation. Protocol is applied on all the sources and sinks as 
default where
+      <code>bootstrap.servers</code> config matches (for further details 
please see 
<code>spark.kafka.clusters.${cluster}.target.bootstrap.servers.regex</code>)
+      , and can be overridden by setting <code>kafka.security.protocol</code> 
on the source or sink.
 
 Review comment:
   Well, to be nitpicky, the comma goes on the previous line.

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to