build: update kafka client (#619)

Author: venikkin

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()))

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>