Fixed kafka errors

module-server/src/main/kotlin/de/twomartens/wahlrecht/configuration/KafkaConfiguration.kt

@@ -0,0 +1,20 @@
+package de.twomartens.wahlrecht.configuration
+
+import org.apache.kafka.clients.admin.AdminClientConfig
+import org.springframework.beans.factory.annotation.Value
+import org.springframework.context.annotation.Bean
+import org.springframework.context.annotation.Configuration
+import org.springframework.kafka.core.KafkaAdmin
+
+@Configuration
+open class KafkaConfiguration {
+  @Value(value = "\${spring.kafka.bootstrap-servers[0]}")
+  private val bootstrapServers: List<String> = mutableListOf()
+
+  @Bean
+  open fun kafkaAdmin(): KafkaAdmin {
+    val configs: MutableMap<String, Any?> = HashMap()
+    configs[AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG] = bootstrapServers.first()
+    return KafkaAdmin(configs)
+  }
+}

module-server/src/main/resources/application-prod.yaml

@@ -3,11 +3,5 @@ spring:
     import:
       - "configserver:${CONFIGSERVER_SCHEME:http}://${CONFIGSERVER_HOST:configserver}:${CONFIGSERVER_PORT:8888}${CONFIGSERVER_PREFIX:/config}"
   kafka:
-    producer:
-      bootstrap-servers:
-        - ${KAFKA_HOST:kafka}:${KAFKA_PORT:9092}
-    consumer:
-      bootstrap-servers:
-        - ${KAFKA_HOST:kafka}:${KAFKA_PORT:9092}
     bootstrap-servers:
       - ${KAFKA_HOST:kafka}:${KAFKA_PORT:9092}