From ec23bd4d32913166dc44f1cab8a34ab64a849d47 Mon Sep 17 00:00:00 2001
From: Jim Martens <github@2martens.de>
Date: Thu, 17 Aug 2023 00:53:05 +0200
Subject: [PATCH] Connect with kafka using bootstrap servers

---
 .../configuration/KafkaConfiguration.kt        | 18 ------------------
 .../src/main/resources/application.yaml        |  4 ++++
 2 files changed, 4 insertions(+), 18 deletions(-)
 delete 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
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: