From 868875a31f7c3a50f5b561f028c5b6d080eb68ed Mon Sep 17 00:00:00 2001
From: Eugene Rubanov <eugene.rubanov@neo4j.com>
Date: Mon, 18 Mar 2024 09:59:53 +0000
Subject: [PATCH] build: update kafka client (#619)

---
 .../streams/service/sink/errors/KafkaErrorServiceTest.kt       | 2 +-
 pom.xml                                                        | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/common/src/test/kotlin/streams/service/sink/errors/KafkaErrorServiceTest.kt b/common/src/test/kotlin/streams/service/sink/errors/KafkaErrorServiceTest.kt
index cab6e95d..f1557b31 100644
--- a/common/src/test/kotlin/streams/service/sink/errors/KafkaErrorServiceTest.kt
+++ b/common/src/test/kotlin/streams/service/sink/errors/KafkaErrorServiceTest.kt
@@ -24,7 +24,7 @@ class KafkaErrorServiceTest {
         val counter = AtomicInteger(0)
         Mockito.`when`(producer.send(ArgumentMatchers.any<ProducerRecord<ByteArray, ByteArray>>())).then {
             counter.incrementAndGet()
-            FutureRecordMetadata(null, 0, RecordBatch.NO_TIMESTAMP, 0, 0, 0, SystemTime())
+            FutureRecordMetadata(null, 0, RecordBatch.NO_TIMESTAMP, 0, 0, SystemTime())
         }
         val dlqService = KafkaErrorService(producer, ErrorService.ErrorConfig(fail=false,dlqTopic = "dlqTopic"), { s, e -> })
         dlqService.report(listOf(dlqData()))
diff --git a/pom.xml b/pom.xml
index 53c669fc..61fe908a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -54,7 +54,8 @@
         <kotlin.version>1.9.10</kotlin.version>
         <kotlin.coroutines.version>1.7.3</kotlin.coroutines.version>
         <neo4j.version>4.4.25</neo4j.version>
-        <kafka.version>2.6.3</kafka.version>
+        <!-- 3.4 is the minimum version for CVE-2023-25194 -->
+        <kafka.version>3.4.1</kafka.version>
         <!-- Keep it at 2.14 as future versions cause problems with neo4j procedure framework -->
         <jackson.version>2.14.3</jackson.version>
         <kotlin.compiler.incremental>true</kotlin.compiler.incremental>