build: upgrade kafka library (#768)

Author: ali-ince

common/src/test/kotlin/streams/service/sink/errors/KafkaErrorServiceTest.kt

@@ -5,7 +5,7 @@ import org.apache.kafka.clients.producer.MockProducer
 import org.apache.kafka.clients.producer.ProducerRecord
 import org.apache.kafka.clients.producer.internals.FutureRecordMetadata
 import org.apache.kafka.common.record.RecordBatch
-import org.apache.kafka.common.utils.SystemTime
+import org.apache.kafka.common.utils.Time
 import org.junit.Test
 import org.mockito.ArgumentMatchers
 import org.mockito.Mockito
@@ -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, SystemTime())
+            FutureRecordMetadata(null, 0, RecordBatch.NO_TIMESTAMP, 0, 0, Time.SYSTEM)
         }
         val dlqService = KafkaErrorService(producer, ErrorService.ErrorConfig(fail=false,dlqTopic = "dlqTopic"), { s, e -> })
         dlqService.report(listOf(dlqData()))

pom.xml

@@ -58,7 +58,7 @@
         <junit-5.version>5.13.1</junit-5.version>
         <junit.version>4.13.2</junit.version>
         <kafka.avro.serializer.version>7.5.1</kafka.avro.serializer.version>
-        <kafka.version>3.8.1</kafka.version>
+        <kafka.version>3.9.1</kafka.version>
         <kotlin.compiler.incremental>true</kotlin.compiler.incremental>
         <kotlin.coroutines.version>1.10.2</kotlin.coroutines.version>
         <kotlin.version>2.1.21</kotlin.version>