Skip to content

Commit

Permalink
Force kafka 3.1.2 for expansion-service jar (#32703) (#32708)
Browse files Browse the repository at this point in the history
Signed-off-by: Jeffrey Kinard <jeff@thekinards.com>
Co-authored-by: Jeff Kinard <jeff@thekinards.com>
  • Loading branch information
Abacn and Polber authored Oct 9, 2024
1 parent f61c8e1 commit 75422cb
Showing 1 changed file with 7 additions and 2 deletions.
9 changes: 7 additions & 2 deletions sdks/java/io/expansion-service/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,12 @@ applyJavaNature(
shadowClosure: {},
)

// TODO(https://github.com/apache/beam/pull/32486/) Use library.java.kafka_clients once >=3.1.0 is set as default
configurations.runtimeClasspath {
// Pin kafka-clients version due to <3.1.0 missing auth callback classes
resolutionStrategy.force 'org.apache.kafka:kafka-clients:3.1.2'
}

shadowJar {
mergeServiceFiles()
}
Expand All @@ -52,8 +58,7 @@ dependencies {
runtimeOnly ("org.apache.iceberg:iceberg-hive-metastore:1.4.2")
runtimeOnly project(path: ":sdks:java:io:iceberg:hive:exec", configuration: "shadow")

// TODO(https://github.com/apache/beam/pull/32486/) Use library.java.kafka_clients once 3.1.2 is set as default
runtimeOnly ("org.apache.kafka:kafka-clients:3.1.2")
runtimeOnly library.java.kafka_clients
runtimeOnly library.java.slf4j_jdk14
}

Expand Down

0 comments on commit 75422cb

Please sign in to comment.