diff --git a/src/main/java/kutaverse/game/config/KafkaConsumerConfig.java b/src/main/java/kutaverse/game/config/KafkaConsumerConfig.java index 6f9f1ed..4e15b56 100644 --- 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 consumerFactory(){ Map properties = new HashMap<>(); - properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,"172.31.33.10:9094"); + properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,"172.31.38.20: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);