feat :: kafka 환경변수

Author: ByunDohwi

src/main/kotlin/dsm/pick2024/global/config/kafka/KafkaConfig.kt

@@ -2,6 +2,7 @@ package dsm.pick2024.global.config.kafka
 
 import org.apache.kafka.clients.consumer.ConsumerConfig
 import org.apache.kafka.common.serialization.StringDeserializer
+import org.springframework.beans.factory.annotation.Value
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
 import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory
@@ -12,7 +13,10 @@ import org.springframework.kafka.listener.ConcurrentMessageListenerContainer
 import org.springframework.kafka.listener.ContainerProperties
 
 @Configuration
-class KafkaConfig {
+class KafkaConfig(
+    @Value("\${spring.kafka.bootstrap-servers}")
+    private val bootstrap_server: String
+) {
     @Bean
     fun kafkaListenerContainerFactory():
         KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> {
@@ -32,7 +36,7 @@ class KafkaConfig {
     @Bean
     fun consumerConfig(): Map<String, Any> {
         val props: MutableMap<String, Any> = HashMap()
-        props[ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG] = "localhost:9092"
+        props[ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG] = bootstrap_server
         props[ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG] = StringDeserializer::class.java
         props[ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG] = StringDeserializer::class.java
 

src/main/resources/application.yaml

@@ -43,7 +43,8 @@ spring:
           enabled: false
 
     kafka:
-        bootstrap-servers: localhost:29092
+        bootstrap-servers: ${BOOTSTRAP_SERVERS}
+
         producer:
             key-serializer: org.apache.kafka.common.serialization.StringSerializer
             value-serializer: org.apache.kafka.common.serialization.StringSerializer