Add Kafka 3 to and remove Kafka 0.x and 1.x from compatibility test (#…

…32981) * Add Kafka 3.1.2 IT target Signed-off-by: Jeffrey Kinard <[email protected]> * Remove kafka 0.x and 1.x from compatibilty test --------- Signed-off-by: Jeffrey Kinard <[email protected]> Co-authored-by: Jeffrey Kinard <[email protected]>
apache · Nov 6, 2024 · eeebae1 · eeebae1
1 parent 13049a5
commit eeebae1
Show file tree

Hide file tree

Showing 5 changed files with 3 additions and 84 deletions.
diff --git a/sdks/java/io/kafka/build.gradle b/sdks/java/io/kafka/build.gradle
@@ -35,9 +35,6 @@ ext {
 }
 
 def kafkaVersions = [
-    '01103': "0.11.0.3",
-    '100': "1.0.0",
-    '111': "1.1.1",
     '201': "2.0.1",
     '211': "2.1.1",
     '222': "2.2.2",
@@ -139,15 +136,13 @@ task kafkaVersionsCompatibilityTest {
   description = 'Runs KafkaIO with different Kafka client APIs'
   def testNames = createTestList(kafkaVersions, "Test")
   dependsOn testNames
-  dependsOn (":sdks:java:io:kafka:kafka-01103:kafkaVersion01103BatchIT")
-  dependsOn (":sdks:java:io:kafka:kafka-100:kafkaVersion100BatchIT")
-  dependsOn (":sdks:java:io:kafka:kafka-111:kafkaVersion111BatchIT")
   dependsOn (":sdks:java:io:kafka:kafka-201:kafkaVersion201BatchIT")
   dependsOn (":sdks:java:io:kafka:kafka-211:kafkaVersion211BatchIT")
   dependsOn (":sdks:java:io:kafka:kafka-222:kafkaVersion222BatchIT")
   dependsOn (":sdks:java:io:kafka:kafka-231:kafkaVersion231BatchIT")
   dependsOn (":sdks:java:io:kafka:kafka-241:kafkaVersion241BatchIT")
   dependsOn (":sdks:java:io:kafka:kafka-251:kafkaVersion251BatchIT")
+  dependsOn (":sdks:java:io:kafka:kafka-312:kafkaVersion312BatchIT")
 }
 
 static def createTestList(Map<String, String> prefixMap, String suffix) {

diff --git a/sdks/java/io/kafka/kafka-01103/build.gradle b/sdks/java/io/kafka/kafka-01103/build.gradle
diff --git a/sdks/java/io/kafka/kafka-100/build.gradle b/sdks/java/io/kafka/kafka-100/build.gradle
diff --git a/sdks/java/io/kafka/kafka-111/build.gradle b/sdks/java/io/kafka/kafka-111/build.gradle
diff --git a/settings.gradle.kts b/settings.gradle.kts
@@ -333,6 +333,8 @@ project(":beam-test-gha").projectDir = file(".github")
 include("beam-validate-runner")
 project(":beam-validate-runner").projectDir = file(".test-infra/validate-runner")
 include("com.google.api.gax.batching")
+include("sdks:java:io:kafka:kafka-312")
+findProject(":sdks:java:io:kafka:kafka-312")?.name = "kafka-312"
 include("sdks:java:io:kafka:kafka-251")
 findProject(":sdks:java:io:kafka:kafka-251")?.name = "kafka-251"
 include("sdks:java:io:kafka:kafka-241")
@@ -345,12 +347,6 @@ include("sdks:java:io:kafka:kafka-211")
 findProject(":sdks:java:io:kafka:kafka-211")?.name = "kafka-211"
 include("sdks:java:io:kafka:kafka-201")
 findProject(":sdks:java:io:kafka:kafka-201")?.name = "kafka-201"
-include("sdks:java:io:kafka:kafka-111")
-findProject(":sdks:java:io:kafka:kafka-111")?.name = "kafka-111"
-include("sdks:java:io:kafka:kafka-100")
-findProject(":sdks:java:io:kafka:kafka-100")?.name = "kafka-100"
-include("sdks:java:io:kafka:kafka-01103")
-findProject(":sdks:java:io:kafka:kafka-01103")?.name = "kafka-01103"
 include("sdks:java:managed")
 findProject(":sdks:java:managed")?.name = "managed"
 include("sdks:java:io:iceberg")