Connect with kafka using bootstrap servers

2023-08-17 00:53:05 +02:00
parent bab1892673
commit ec23bd4d32
2 changed files with 4 additions and 18 deletions
@@ -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"))
-}
@@ -28,6 +28,10 @@ spring:
      name: wahlrecht
  main:
    banner-mode: off
+  kafka:
+    bootstrap-servers:
+      - localhost:9092
+      - kafka:9092
  profiles:
    default: dev
  data.mongodb: