Add deserializer config

navikt · Oct 17, 2023 · b7ab09a · b7ab09a
1 parent 65bcaea
commit b7ab09a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/kotlin/no/nav/syfo/kafka/config/AivenKafkaConfig.kt b/src/main/kotlin/no/nav/syfo/kafka/config/AivenKafkaConfig.kt
@@ -1,5 +1,6 @@
 package no.nav.syfo.kafka.config
 
+import com.fasterxml.jackson.databind.deser.std.StringDeserializer
 import org.apache.kafka.clients.CommonClientConfigs
 import org.apache.kafka.clients.CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG
 import org.apache.kafka.clients.consumer.ConsumerConfig
@@ -48,6 +49,8 @@ class AivenKafkaConfig(
         val config = mapOf(
             ConsumerConfig.GROUP_ID_CONFIG to "aktivitetskrav-backend-group",
             ConsumerConfig.AUTO_OFFSET_RESET_CONFIG to kafkaAutoOffsetReset,
+            ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG to StringDeserializer::class.java,
+            ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG to StringDeserializer::class.java,
             ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG to false,
             ConsumerConfig.MAX_POLL_RECORDS_CONFIG to "1",
             ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG to "600000"