Added kafka server config

2023-08-17 00:42:53 +02:00
parent 247fe83caa
commit ef31f9046b
1 changed files with 18 additions and 0 deletions
@@ -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"))
+}