[BEAM-8774 BEAM-11375] Update scala version of Kafka dependency

apache · Dec 2, 2020 · 2216e81 · 2216e81
1 parent 83ed9ae
commit 2216e81
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy b/buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy
@@ -438,6 +438,7 @@ class BeamModulePlugin implements Plugin<Project> {
     def influxdb_version = "2.19"
     def jackson_version = "2.10.2"
     def jaxb_api_version = "2.3.3"
+    def kafka_version = "2.6.0"
     def nemo_version = "0.1"
     def netty_version = "4.1.51.Final"
     def postgres_version = "42.2.16"
@@ -577,8 +578,8 @@ class BeamModulePlugin implements Plugin<Project> {
         jsonassert                                  : "org.skyscreamer:jsonassert:1.5.0",
         jsr305                                      : "com.google.code.findbugs:jsr305:3.0.2",
         junit                                       : "junit:junit:4.13-beta-3",
-        kafka                                       : "org.apache.kafka:kafka_2.11:2.4.1",
-        kafka_clients                               : "org.apache.kafka:kafka-clients:2.6.0",
+        kafka                                       : "org.apache.kafka:kafka_2.13:$kafka_version",
+        kafka_clients                               : "org.apache.kafka:kafka-clients:$kafka_version",
         mockito_core                                : "org.mockito:mockito-core:3.0.0",
         nemo_compiler_frontend_beam                 : "org.apache.nemo:nemo-compiler-frontend-beam:$nemo_version",
         netty_all                                   : "io.netty:netty-all:$netty_version",