From bab1892673bde06ab25435c6d5be3bfe85067099 Mon Sep 17 00:00:00 2001 From: Jim Martens Date: Thu, 17 Aug 2023 00:42:53 +0200 Subject: [PATCH] Added kafka server config --- .../configuration/KafkaConfiguration.kt | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) create mode 100644 module-server/src/main/kotlin/de/twomartens/wahlrecht/configuration/KafkaConfiguration.kt diff --git a/module-server/src/main/kotlin/de/twomartens/wahlrecht/configuration/KafkaConfiguration.kt b/module-server/src/main/kotlin/de/twomartens/wahlrecht/configuration/KafkaConfiguration.kt new file mode 100644 index 0000000..f589a23 --- /dev/null +++ b/module-server/src/main/kotlin/de/twomartens/wahlrecht/configuration/KafkaConfiguration.kt @@ -0,0 +1,18 @@ +package de.twomartens.wahlrecht.configuration + +import org.apache.kafka.clients.admin.AdminClientConfig +import org.springframework.context.annotation.Bean +import org.springframework.context.annotation.Configuration +import org.springframework.context.annotation.Profile +import org.springframework.kafka.core.KafkaAdmin + +@Configuration +open class KafkaConfiguration { + @Bean + @Profile("prod") + open fun kafkaProd() = KafkaAdmin(mapOf(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG to "kafka:9092")) + + @Bean + @Profile("dev") + open fun kafkaDev() = KafkaAdmin(mapOf(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG to "localhost:9092")) +}