From 92f37c936ff7c48fb367461eface2b44262826c3 Mon Sep 17 00:00:00 2001 From: kamothi Date: Tue, 8 Oct 2024 22:38:13 +0900 Subject: [PATCH] =?UTF-8?q?fix:=20broker=20=EC=A3=BC=EC=86=8C=20=EB=B3=80?= =?UTF-8?q?=EA=B2=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/kutaverse/game/config/KafkaConsumerConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/kutaverse/game/config/KafkaConsumerConfig.java b/src/main/java/kutaverse/game/config/KafkaConsumerConfig.java index 4e15b56..c724ea0 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.38.20:9094"); + properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,"172.31.38.20:9092"); 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);