Add Kafka server config
continuous-integration/drone/push Build is passing Details

This commit is contained in:
Jim Martens 2023-08-17 00:43:50 +02:00
parent bbb573d626
commit a1da4309a3
1 changed files with 13 additions and 1 deletions

View File

@ -1,12 +1,24 @@
package de.twomartens.configserver
import org.apache.kafka.clients.admin.AdminClientConfig
import org.springframework.boot.autoconfigure.SpringBootApplication
import org.springframework.boot.runApplication
import org.springframework.cloud.config.server.EnableConfigServer
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Profile
import org.springframework.kafka.core.KafkaAdmin
@SpringBootApplication
@EnableConfigServer
open class MainApplication
open class MainApplication {
@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"))
}
fun main(args: Array<String>) {
runApplication<MainApplication>(*args)