Skip to content

Commit

Permalink
[SPARK-32568][BUILD][SS] Upgrade Kafka to 2.6.0
Browse files Browse the repository at this point in the history
### What changes were proposed in this pull request?

This PR aims to update Kafka client library to 2.6.0 for Apache Spark 3.1.0.

### Why are the changes needed?

This will bring client-side bug fixes like KAFKA-10134 and KAFKA-10223.

### Does this PR introduce _any_ user-facing change?

No.

### How was this patch tested?

Pass the existing tests.

Closes #29386 from dongjoon-hyun/SPARK-32568.

Authored-by: Dongjoon Hyun <[email protected]>
Signed-off-by: HyukjinKwon <[email protected]>
  • Loading branch information
dongjoon-hyun authored and HyukjinKwon committed Aug 8, 2020
1 parent 5b8444a commit eb74d55
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -395,7 +395,7 @@ class KafkaTestUtils(
}

def getAllTopicsAndPartitionSize(): Seq[(String, Int)] = {
zkClient.getPartitionsForTopics(zkClient.getAllTopicsInCluster).mapValues(_.size).toSeq
zkClient.getPartitionsForTopics(zkClient.getAllTopicsInCluster()).mapValues(_.size).toSeq
}

/** Create a Kafka topic and wait until it is propagated to the whole cluster */
Expand Down Expand Up @@ -587,7 +587,7 @@ class KafkaTestUtils(
}), s"checkpoint for topic $topic still exists")
// ensure the topic is gone
assert(
!zkClient.getAllTopicsInCluster.contains(topic),
!zkClient.getAllTopicsInCluster().contains(topic),
s"topic $topic still exists on zookeeper")
}

Expand Down
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -133,7 +133,7 @@
<!-- Version used for internal directory structure -->
<hive.version.short>2.3</hive.version.short>
<!-- note that this should be compatible with Kafka brokers version 0.10 and up -->
<kafka.version>2.5.0</kafka.version>
<kafka.version>2.6.0</kafka.version>
<derby.version>10.12.1.1</derby.version>
<parquet.version>1.10.1</parquet.version>
<orc.version>1.5.10</orc.version>
Expand Down

0 comments on commit eb74d55

Please sign in to comment.