boyuanzz commented on a change in pull request #13026:
URL: https://github.com/apache/beam/pull/13026#discussion_r524517625



##########
File path: sdks/java/io/kafka/build.gradle
##########
@@ -65,26 +76,68 @@ dependencies {
   testCompile library.java.junit
   testCompile library.java.powermock
   testCompile library.java.powermock_mockito
+  testCompile library.java.testcontainers_kafka
   testRuntimeOnly library.java.slf4j_jdk14
   testRuntimeOnly project(path: ":runners:direct-java", configuration: 
"shadow")
-  kafkaVersion210 "org.apache.kafka:kafka-clients:2.1.0"
+  kafkaVersions.each {"kafkaVersion$it.key" 
"org.apache.kafka:kafka-clients:$it.value"}
 }
 
-configurations.kafkaVersion210 {
-  resolutionStrategy {
-    force "org.apache.kafka:kafka-clients:2.1.0"
+kafkaVersions.each { kv ->
+  configurations."kafkaVersion$kv.key" {
+    resolutionStrategy {
+      force "org.apache.kafka:kafka-clients:$kv.value"
+    }
   }
 }
 
-task kafkaVersion210Test(type: Test) {

Review comment:
       So the problem is introduced by 
https://github.com/apache/beam/pull/13283/files




----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to