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 deleted file mode 100644 index f589a23..0000000 --- a/module-server/src/main/kotlin/de/twomartens/wahlrecht/configuration/KafkaConfiguration.kt +++ /dev/null @@ -1,18 +0,0 @@ -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")) -} diff --git a/module-server/src/main/resources/application.yaml b/module-server/src/main/resources/application.yaml index 0b67c6b..7baf4c1 100644 --- a/module-server/src/main/resources/application.yaml +++ b/module-server/src/main/resources/application.yaml @@ -28,6 +28,10 @@ spring: name: wahlrecht main: banner-mode: off + kafka: + bootstrap-servers: + - localhost:9092 + - kafka:9092 profiles: default: dev data.mongodb: