feat(be): consumer 멀티 스레드 3으로 증가

- jootalkpia.chat.prd.message Topic의 partitions 개수 3으로 증가로 인한 변경

Author: ki-met-hoon

src/backend/chat_server/src/main/java/com/jootalkpia/chat_server/service/KafkaConsumer.java

@@ -41,7 +41,7 @@ public void processMinutePrice(String kafkaMessage) {
     @KafkaListener(
             topics = "${topic.chat}",
             groupId = "${group.chat}",
-            concurrency = "2"
+            concurrency = "3"
     )
     public void processChatMessage(@Header(KafkaHeaders.RECEIVED_KEY) String channelId, String kafkaMessage) {
         log.info("Received Kafka chat message ===> channelId: {}, message: {}", channelId, kafkaMessage);
@@ -59,8 +59,7 @@ public void processChatMessage(@Header(KafkaHeaders.RECEIVED_KEY) String channel
 
     @KafkaListener(
             topics = "${topic.push}",
-            groupId = "${group.push}",
-            concurrency = "2"
+            groupId = "${group.push}"
     )
     public void processPushMessage(String kafkaMessage) {
         log.info("message ===> " + kafkaMessage);

src/backend/state_server/src/main/java/com/jootalkpia/state_server/service/KafkaConsumer.java

@@ -21,7 +21,8 @@ public class KafkaConsumer {
 
     @KafkaListener(
             topics = "${topic.chat}",
-            groupId = "${group.status}"
+            groupId = "${group.status}",
+            concurrency = "3"
     )
     public void processState(String kafkaMessage) {
         log.info("message ===> " + kafkaMessage);