Merge pull request #420 from TrandPick/development

refactor: 배포환경에 따른 변수명 변경 (#415)
TrandPick · Aug 13, 2023 · 6ad7940 · 6ad7940
2 parents a687135 + 7828af3
commit 6ad7940
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/project/trendpick_pro/global/config/KafkaConfig.java b/src/main/java/project/trendpick_pro/global/config/KafkaConfig.java
@@ -34,7 +34,7 @@ public class KafkaConfig {
     @Bean
     public KafkaAdmin admin() {
         Map<String, Object> configs = new HashMap<>();
-        configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:"+kafkaPort);
+        configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaHost+kafkaPort);
         return new KafkaAdmin(configs);
     }