Uh oh!
There was an error while loading. Please reload this page.
[SPARK-28055][SS][DSTREAMS] Add delegation token custom AdminClient configurations. - #24875
[SPARK-28055][SS][DSTREAMS] Add delegation token custom AdminClient configurations.#24875gaborgsomogyi wants to merge 4 commits into
Conversation
gaborgsomogyi
commented
Jun 14, 2019
@koertkuipers the feature is on the way what we've spoken about. Ping me if you think this area lacks something. |
SparkQA
commented
Jun 14, 2019
Test build #106513 has finished for PR 24875 at commit
|
koertkuipers
commented
Jun 14, 2019
looks good to me |
gaborgsomogyi
commented
Jun 25, 2019
cc @vanzin |
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
koertkuipers
commented
Jun 30, 2019
this branch works for me to set |
Co-Authored-By: Marcelo Vanzin <vanzin@gmail.com>
gaborgsomogyi
commented
Jul 1, 2019
@koertkuipers Thanks for testing it! |
SparkQA
commented
Jul 1, 2019
Test build #107072 has finished for PR 24875 at commit
|
SparkQA
commented
Jul 1, 2019
Test build #107077 has finished for PR 24875 at commit
|
SparkQA
commented
Jul 1, 2019
Test build #107075 has finished for PR 24875 at commit
|
vanzin
commented
Jul 10, 2019
retest this please |
SparkQA
commented
Jul 11, 2019
Test build #107488 has finished for PR 24875 at commit
|
vanzin
commented
Jul 11, 2019
Merging to master. |
…onfigurations. ## What changes were proposed in this pull request? At the moment Kafka delegation tokens are fetched through `AdminClient` but there is no possibility to add custom configuration parameters. In [options](https://spark.apache.org/docs/2.4.3/structured-streaming-kafka-integration.html#kafka-specific-configurations) there is already a possibility to add custom configurations. In this PR I've added similar this possibility to `AdminClient`. ## How was this patch tested? Existing + added unit tests. ``` cd docs/ SKIP_API=1 jekyll build ``` Manual webpage check. Closesapache#24875 from gaborgsomogyi/SPARK-28055. Authored-by: Gabor Somogyi <gabor.g.somogyi@gmail.com> Signed-off-by: Marcelo Vanzin <vanzin@cloudera.com>
What changes were proposed in this pull request?
At the moment Kafka delegation tokens are fetched through
AdminClientbut there is no possibility to add custom configuration parameters. In options there is already a possibility to add custom configurations.In this PR I've added similar this possibility to
AdminClient.How was this patch tested?
Existing + added unit tests.
Manual webpage check.