diff --git a/src/main/kotlin/no/nav/syfo/kafka/config/AivenKafkaConfig.kt b/src/main/kotlin/no/nav/syfo/kafka/config/AivenKafkaConfig.kt index ca90ffd..73326ea 100644 --- 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"