Issue neo4j-contrib#549: Upgrade kafka-avro-serializer dependency

mroiter-larus · Jul 25, 2023 · 64eb86e · 64eb86e
1 parent 66894ec
commit 64eb86e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/common/src/main/kotlin/streams/extensions/CommonExtensions.kt b/common/src/main/kotlin/streams/extensions/CommonExtensions.kt
@@ -74,7 +74,7 @@ private fun convertAvroData(rawValue: Any?): Any? = when (rawValue) {
             .mapValues { convertAvroData(it.value) }
     is GenericFixed -> rawValue.bytes()
     is ByteBuffer -> rawValue.array()
-    is GenericEnumSymbol, is CharSequence -> rawValue.toString()
+    is GenericEnumSymbol<*>, is CharSequence -> rawValue.toString()
     else -> rawValue
 }
 fun IndexedRecord.toMap() = this.schema.fields

diff --git a/common/src/test/kotlin/streams/service/sink/errors/KafkaErrorServiceTest.kt b/common/src/test/kotlin/streams/service/sink/errors/KafkaErrorServiceTest.kt
@@ -25,7 +25,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, 0L, 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()))