GitHub user gaborgsomogyi opened a pull request:
https://github.com/apache/spark/pull/23274
[SPARK-26322][SS] Add spark.kafka.token.sasl.mechanism to ease delegation
token configuration.
## What changes were proposed in this pull request?
When Kafka delegation token obtained, SCRAM `sasl.mechanism` has to be
configured for authentication. This can be configured on the related
source/sink which is inconvenient from user perspective. Such granularity is
not required and this configuration can be implemented with one central
parameter.
In this PR `spark.kafka.token.sasl.mechanism` added to configure this
centrally (default: `SCRAM-SHA-512`).
## How was this patch tested?
Existing unit tests + on cluster.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/gaborgsomogyi/spark SPARK-26322
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/spark/pull/23274.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #23274
----
commit 320040a90c58c87ce1b21ba6fdc16b703122e8b1
Author: Gabor Somogyi <gabor.g.somogyi@...>
Date: 2018-12-07T15:02:17Z
[SPARK-26322][SS] Add spark.kafka.token.sasl.mechanism to ease delegation
token configuration.
----
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
