(beam) branch release-2.60.0 updated: Force kafka 3.1.2 for expansion-service jar (#32703) (#32708)

[damccorm]

This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a commit to branch release-2.60.0
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/release-2.60.0 by this push:
     new 75422cb58ac Force kafka 3.1.2 for expansion-service jar (#32703) 
(#32708)
75422cb58ac is described below

commit 75422cb58acf68f6323fb5c270ee56886a9e11bf
Author: Yi Hu <ya...@google.com>
AuthorDate: Wed Oct 9 09:19:02 2024 -0400

    Force kafka 3.1.2 for expansion-service jar (#32703) (#32708)
    
    Signed-off-by: Jeffrey Kinard <j...@thekinards.com>
    Co-authored-by: Jeff Kinard <j...@thekinards.com>
---
 sdks/java/io/expansion-service/build.gradle | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/sdks/java/io/expansion-service/build.gradle 
b/sdks/java/io/expansion-service/build.gradle
index d7fef3d8233..26a001b6ea2 100644
--- a/sdks/java/io/expansion-service/build.gradle
+++ b/sdks/java/io/expansion-service/build.gradle
@@ -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()
 }
@@ -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
 }