From e3072df328d5a89c2bb05ad2a93e456c7450a808 Mon Sep 17 00:00:00 2001 From: Magnus Evensberget Date: Wed, 9 Jun 2021 12:44:27 +0200 Subject: [PATCH] Koblet til brukernotifikasjon --- .../config/kafka/utils/props/KafkaAvroProducerProperties.kt | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/kotlin/no/nav/fo/veilarbvarsel/config/kafka/utils/props/KafkaAvroProducerProperties.kt b/src/main/kotlin/no/nav/fo/veilarbvarsel/config/kafka/utils/props/KafkaAvroProducerProperties.kt index 95a3aac..86bb19e 100644 --- a/src/main/kotlin/no/nav/fo/veilarbvarsel/config/kafka/utils/props/KafkaAvroProducerProperties.kt +++ b/src/main/kotlin/no/nav/fo/veilarbvarsel/config/kafka/utils/props/KafkaAvroProducerProperties.kt @@ -1,5 +1,6 @@ package no.nav.fo.veilarbvarsel.config.kafka.utils.props +import io.confluent.kafka.serializers.AbstractKafkaAvroSerDeConfig import io.confluent.kafka.serializers.KafkaAvroSerializer import no.nav.common.kafka.util.KafkaPropertiesPreset.onPremDefaultProducerProperties import no.nav.common.utils.NaisUtils @@ -16,7 +17,7 @@ data class KafkaAvroProducerProperties(val env: KafkaEnvironment) { //properties[ProducerConfig.BOOTSTRAP_SERVERS_CONFIG] = env.bootstrapServers properties[ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG] = KafkaAvroSerializer::class.java properties[ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG] = KafkaAvroSerializer::class.java - //properties[AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG] = env.schemaRegistryUrl + properties[AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG] = env.schemaRegistryUrl return properties }