Merge pull request #4 from KU-Taverse/fix/config

[fix] broker 주소 변경
KU-Taverse · Oct 8, 2024 · dca2479 · dca2479
2 parents 59eef17 + fe59ae0
commit dca2479
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/kutaverse/game/config/KafkaConsumerConfig.java b/src/main/java/kutaverse/game/config/KafkaConsumerConfig.java
@@ -19,7 +19,7 @@ public class KafkaConsumerConfig {
     public ConsumerFactory<String, String> consumerFactory(){
         Map<String, Object> properties = new HashMap<>();
 
-        properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,"127.0.0.1:9092");
+        properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,"172.31.33.10:9094");
         properties.put(ConsumerConfig.GROUP_ID_CONFIG,"consumerGroupId");
         properties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
         properties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);