6c178a5d16
### What changes were proposed in this pull request? Spark SQL Kafka consumer connector considers delegation token usage even if the user configures `sasl.jaas.config` manually. In this PR I've added `spark.security.credentials.kafka.enabled` and cluster configuration check to the condition. ### Why are the changes needed? Now it's not possible to configure `sasl.jaas.config` manually. ### Does this PR introduce any user-facing change? No. ### How was this patch tested? Existing + additional unit tests. Closes #27191 from gaborgsomogyi/SPARK-30495. Authored-by: Gabor Somogyi <gabor.g.somogyi@gmail.com> Signed-off-by: Marcelo Vanzin <vanzin@cloudera.com> |
||
|---|---|---|
| .. | ||
| avro | ||
| docker | ||
| docker-integration-tests | ||
| kafka-0-10 | ||
| kafka-0-10-assembly | ||
| kafka-0-10-sql | ||
| kafka-0-10-token-provider | ||
| kinesis-asl | ||
| kinesis-asl-assembly | ||
| spark-ganglia-lgpl | ||