test(be): consumer 멀티 스레드 값 변경

Author: ki-met-hoon

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

@@ -40,7 +40,8 @@ public void processMinutePrice(String kafkaMessage) {
 
     @KafkaListener(
             topics = "${topic.chat}",
-            groupId = "${group.chat}"
+            groupId = "${group.chat}",
+            concurrency = "3"
     )
     public void processChatMessage(@Header(KafkaHeaders.RECEIVED_KEY) String channelId, String kafkaMessage) {
         try {
@@ -56,7 +57,7 @@ public void processChatMessage(@Header(KafkaHeaders.RECEIVED_KEY) String channel
     @KafkaListener(
             topics = "${topic.push}",
             groupId = "${group.push}",
-            concurrency = "5"
+            concurrency = "8"
     )
     public void processPushMessage(String kafkaMessage) {
         try {

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) {
         ObjectMapper mapper = new ObjectMapper();