Fikset KClass istedenfor java class i kafka cfg

navikt · Nov 15, 2024 · 7592fa9 · 7592fa9
1 parent 8e1d85d
commit 7592fa9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/kafka/src/main/kotlin/no/nav/paw/config/kafka/KafkaFactory.kt b/lib/kafka/src/main/kotlin/no/nav/paw/config/kafka/KafkaFactory.kt
@@ -40,7 +40,7 @@ class KafkaFactory(private val config: KafkaConfig) {
                     ConsumerConfig.GROUP_ID_CONFIG to groupId,
                     ConsumerConfig.CLIENT_ID_CONFIG to clientId,
                     ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG to keyDeserializer.java,
-                    ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG to KafkaAvroDeserializer::class,
+                    ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG to KafkaAvroDeserializer::class.java,
                     ConsumerConfig.MAX_POLL_RECORDS_CONFIG to maxPollrecords
                 )
     )