Skip to content

Commit ceacd94

Browse files
committed
Fikset feil i opprettelse av Avro props
1 parent 48fd6fe commit ceacd94

File tree

1 file changed

+7
-8
lines changed
  • apps/opplysninger-aggregering/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/config

1 file changed

+7
-8
lines changed

apps/opplysninger-aggregering/src/main/kotlin/no/nav/paw/arbeidssoekerregisteret/config/KafkaSerialization.kt

+7-8
Original file line numberDiff line numberDiff line change
@@ -69,14 +69,13 @@ fun buildAvroSerdeConfig(config: KafkaSchemaRegistryConfig?): Map<String, Any> {
6969
return if (config == null) {
7070
emptyMap()
7171
} else {
72-
mapOf(
73-
KafkaAvroSerializerConfig.SCHEMA_REGISTRY_URL_CONFIG to config.url,
74-
KafkaAvroSerializerConfig.AUTO_REGISTER_SCHEMAS to config.autoRegisterSchema,
75-
KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG to config.avroSpecificReaderConfig
76-
).apply {
77-
config.username?.let {
78-
SchemaRegistryClientConfig.BASIC_AUTH_CREDENTIALS_SOURCE to "USER_INFO"
79-
SchemaRegistryClientConfig.USER_INFO_CONFIG to "${config.username}:${config.password}"
72+
buildMap {
73+
put(KafkaAvroSerializerConfig.SCHEMA_REGISTRY_URL_CONFIG, config.url)
74+
put(KafkaAvroSerializerConfig.AUTO_REGISTER_SCHEMAS, config.autoRegisterSchema)
75+
put(KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG, config.avroSpecificReaderConfig)
76+
if (config.username != null) {
77+
put(SchemaRegistryClientConfig.BASIC_AUTH_CREDENTIALS_SOURCE, "USER_INFO")
78+
put(SchemaRegistryClientConfig.USER_INFO_CONFIG, "${config.username}:${config.password}")
8079
}
8180
}
8281
}

0 commit comments

Comments
 (0)