Merge pull request #340 from 6QuizOnTheBlock/be/feat/#333-send-question

hotfix: 배포 환경에서 Consumer 로 메세지가 안 오는 문제 해결
6QuizOnTheBlock · May 16, 2024 · 156148a · 156148a
2 parents 24d2841 + 7391b81
commit 156148a
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 8 deletions.
diff --git a/backEnd/src/main/java/com/quiz/ourclass/domain/chat/service/message/MessageReceive.java b/backEnd/src/main/java/com/quiz/ourclass/domain/chat/service/message/MessageReceive.java
@@ -17,7 +17,7 @@ public class MessageReceive {
     private final SimpMessageSendingOperations template;
     private final ChatRepository chatRepository;
 
-    @KafkaListener(topics = ConstantUtil.KAFKA_TOPIC, containerFactory = "kafkaListenerContainerFactory")
+    @KafkaListener(topics = ConstantUtil.KAFKA_TOPIC, containerFactory = "chatContainerFactory")
     public void receiveMessage(Message message) {
         log.info("전송 위치 = /subscribe/public/" + message.getRoomId());
         log.info("채팅 방으로 메시지 전송 = {}", message.getContent());

diff --git a/backEnd/src/main/java/com/quiz/ourclass/domain/quiz/service/QuizReceive.java b/backEnd/src/main/java/com/quiz/ourclass/domain/quiz/service/QuizReceive.java
@@ -26,7 +26,7 @@ public class QuizReceive {
     @Value("${kafka.group}")
     String kafkaGroup;
 
-    @KafkaListener(topics = ConstantUtil.QUIZ_GAMER, groupId = "group-id", containerFactory = "gamerListenerContainerFactory", concurrency = "4")
+    @KafkaListener(topics = ConstantUtil.QUIZ_GAMER, groupId = "group-2", containerFactory = "gamerListenerContainerFactory", concurrency = "4")
     public void receivedGamer(GamerDTO gamer) {
         log.info("/gamer/" + gamer.quizGameId());
         log.info("게이머 상세={}", gamer.toString());
@@ -51,7 +51,7 @@ public void receivedGamer(GamerDTO gamer) {
                 (gamer.quizGameId(), redisUtil.getAllMemberScores(gamer.quizGameId())));
     }
 
-    @KafkaListener(topics = ConstantUtil.QUIZ_QUESTION, groupId = "group-id", containerFactory = "questionRequestContainerFactory")
+    @KafkaListener(topics = ConstantUtil.QUIZ_QUESTION, groupId = "group-3", containerFactory = "questionRequestContainerFactory")
     public void receivedQuestion(QuestionRequest request) {
         log.info("보내줘야 할 질문 상세={}", request.toString());
 
@@ -60,7 +60,7 @@ public void receivedQuestion(QuestionRequest request) {
                 request.quizGameId(), request.id()));
     }
 
-    @KafkaListener(topics = ConstantUtil.QUIZ_ANSWER, groupId = "group-id", containerFactory = "answerResponseContainerFactory")
+    @KafkaListener(topics = ConstantUtil.QUIZ_ANSWER, groupId = "group-4", containerFactory = "answerResponseContainerFactory")
     public void receivedAnswer(AnswerResponse response) {
         log.info("보내줘야할 답 상세={}", response.toString());
 

diff --git a/backEnd/src/main/java/com/quiz/ourclass/global/config/kafka/ListenerConfig.java b/backEnd/src/main/java/com/quiz/ourclass/global/config/kafka/ListenerConfig.java
@@ -29,7 +29,7 @@ public class ListenerConfig {
 
     // KafkaListener 컨테이너 팩토리를 생성하는 Bean 메서드
     @Bean
-    ConcurrentKafkaListenerContainerFactory<String, Message> kafkaListenerContainerFactory() {
+    ConcurrentKafkaListenerContainerFactory<String, Message> chatContainerFactory() {
         ConcurrentKafkaListenerContainerFactory<String, Message> factory = new ConcurrentKafkaListenerContainerFactory<>();
         factory.setConsumerFactory(consumerFactory());
         return factory;
@@ -72,7 +72,7 @@ public ConsumerFactory<String, GamerDTO> gamerDTOConsumerFactory() {
         Map<String, Object> consumerConfigurations =
             ImmutableMap.<String, Object>builder()
                 .put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaUrl)
-                .put(ConsumerConfig.GROUP_ID_CONFIG, kafkaGroup)
+                .put(ConsumerConfig.GROUP_ID_CONFIG, "group-2")
                 .put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class)
                 .put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, deserializer)
                 .put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest")
@@ -99,7 +99,7 @@ public ConsumerFactory<String, QuestionRequest> questionRequestConsumerFactory()
         Map<String, Object> consumerConfigurations =
             ImmutableMap.<String, Object>builder()
                 .put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaUrl)
-                .put(ConsumerConfig.GROUP_ID_CONFIG, kafkaGroup)
+                .put(ConsumerConfig.GROUP_ID_CONFIG, "group-3")
                 .put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class)
                 .put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, deserializer)
                 .put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest")
@@ -125,7 +125,7 @@ public ConsumerFactory<String, AnswerResponse> answerResponseConsumerFactory() {
         Map<String, Object> consumerConfigurations =
             ImmutableMap.<String, Object>builder()
                 .put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaUrl)
-                .put(ConsumerConfig.GROUP_ID_CONFIG, kafkaGroup)
+                .put(ConsumerConfig.GROUP_ID_CONFIG, "group-4")
                 .put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class)
                 .put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, deserializer)
                 .put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "latest")