Added kafka server config

Changed config [CI SKIP]
2023-08-17 00:42:53 +02:00 · 2023-08-17 00:36:27 +02:00
2 changed files with 19 additions and 1 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"))
+}
@@ -1,6 +1,6 @@
 de.twomartens.wahlrecht:
  defaultTimeZone: Europe/Berlin
-  greeting: "Hello %s, on dev"
+  greeting: "Hello %s, on millenium"
  statusprobe:
    scheduleDuration: 60
    maxKafkaFailureDuration: 5
Author	SHA1	Message	Date
2martens	bab1892673	Added kafka server config continuous-integration/drone/push Build is failing Details	2023-08-17 00:42:53 +02:00
2martens	247fe83caa	Changed config [CI SKIP]	2023-08-17 00:36:27 +02:00