c6e39dffd6
### What changes were proposed in this pull request? This PR aims to upgrade Kafka library to 2.5.0 for Apache Spark 3.1.0. ### Why are the changes needed? Apache Kafka 2.5.0 client has improvements and bug fixes like [KAFKA-9241](https://issues.apache.org/jira/browse/KAFKA-9241) - https://downloads.apache.org/kafka/2.5.0/RELEASE_NOTES.html ### Does this PR introduce any user-facing change? No. ### How was this patch tested? Pass the Jenkins with the existing tests. - [x] SBT https://github.com/apache/spark/pull/28235#issuecomment-615936382 - [x] Maven https://github.com/apache/spark/pull/28235#issuecomment-616138840 (All Scala/Java/Python/R UT tests passed. It's timeout during R installation testing which is already covered by SBT.) Closes #28235 from dongjoon-hyun/SPARK-KAFKA-2.5. Authored-by: Dongjoon Hyun <dongjoon@apache.org> Signed-off-by: Dongjoon Hyun <dongjoon@apache.org> |
||
---|---|---|
.. | ||
src | ||
pom.xml |