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 }