build: update kafka client and confluent platform (#65)

Author: venikkin

common/src/test/kotlin/org/neo4j/connectors/kafka/service/errors/KafkaErrorServiceTest.kt

@@ -40,7 +40,7 @@ class KafkaErrorServiceTest {
     Mockito.`when`(producer.send(ArgumentMatchers.any<ProducerRecord<ByteArray, ByteArray>>()))
         .then {
           counter.incrementAndGet()
-          FutureRecordMetadata(null, 0, RecordBatch.NO_TIMESTAMP, 0L, 0, 0, SystemTime())
+          FutureRecordMetadata(null, 0, RecordBatch.NO_TIMESTAMP, 0, 0, SystemTime())
         }
     val dlqService =
         KafkaErrorService(

docker/docker-compose.yml

@@ -20,7 +20,7 @@ services:
       retries: 5
 
   zookeeper:
-    image: confluentinc/cp-zookeeper:7.0.11
+    image: confluentinc/cp-zookeeper:7.2.9
     hostname: zookeeper
     container_name: zookeeper
     ports:
@@ -37,7 +37,7 @@ services:
       retries: 5
 
   broker:
-    image: confluentinc/cp-server:7.0.11
+    image: confluentinc/cp-server:7.2.9
     hostname: broker
     container_name: broker
     depends_on:
@@ -73,7 +73,7 @@ services:
       retries: 5
 
   schema-registry:
-    image: confluentinc/cp-schema-registry:7.0.11
+    image: confluentinc/cp-schema-registry:7.2.9
     hostname: schema-registry
     container_name: schema-registry
     depends_on:
@@ -93,7 +93,7 @@ services:
       retries: 5
 
   connect:
-    image: confluentinc/cp-server-connect:7.0.11
+    image: confluentinc/cp-server-connect:7.2.9
     hostname: connect
     container_name: connect
     depends_on:
@@ -137,7 +137,7 @@ services:
       retries: 5
 
   control-center:
-    image: confluentinc/cp-enterprise-control-center:7.0.11
+    image: confluentinc/cp-enterprise-control-center:7.2.9
     hostname: control-center
     container_name: control-center
     depends_on:

pom.xml

@@ -56,8 +56,9 @@
         <junit-jupiter.version>5.10.0</junit-jupiter.version>
         <!-- keep the next two in sync: https://docs.confluent.io/platform/current/installation/versions-interoperability.html -->
         <!-- as well as versions in the docker-compose.yml file -->
-        <kafka-schema-registry.version>6.1.13</kafka-schema-registry.version>
-        <kafka.version>2.7.2</kafka.version>
+        <kafka-schema-registry.version>7.2.9</kafka-schema-registry.version>
+        <!-- kafka connect below 3.4 is vulnerable to https://nvd.nist.gov/vuln/detail/CVE-2023-25194 -->
+        <kafka.version>3.4.1</kafka.version>
         <kotest-assertions-core-jvm.version>5.8.0</kotest-assertions-core-jvm.version>
         <kotlin.coroutines.version>1.7.3</kotlin.coroutines.version>
         <kotlin.version>1.9.0</kotlin.version>
@@ -76,6 +77,7 @@
         <neo4j-cypher-dsl.version>2022.9.1</neo4j-cypher-dsl.version>
         <neo4j-java-driver.version>4.4.9</neo4j-java-driver.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <protobuf.version>3.23.2</protobuf.version>
         <reactor.version>2022.0.11</reactor.version>
         <slf4j.version>1.7.36</slf4j.version>
         <sortpom-maven-plugin.version>3.3.0</sortpom-maven-plugin.version>
@@ -143,6 +145,12 @@
                 <artifactId>logback-classic</artifactId>
                 <version>${logback.version}</version>
             </dependency>
+            <dependency>
+                <!-- dependency of confluent protobuf converter -->
+                <groupId>com.google.protobuf</groupId>
+                <artifactId>protobuf-java</artifactId>
+                <version>${protobuf.version}</version>
+            </dependency>
             <dependency>
                 <groupId>io.confluent</groupId>
                 <artifactId>kafka-avro-serializer</artifactId>