test(be): 멀티 스레드 개수 변경

ki-met-hoon · ki-met-hoon · commit 4d81cbba1a27 · 2025-04-13T02:55:46.000+09:00
diff --git a/src/backend/chat_server/src/main/java/com/jootalkpia/chat_server/service/KafkaConsumer.java b/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 = "5"
+            concurrency = "8"
     )
     public void processChatMessage(@Header(KafkaHeaders.RECEIVED_KEY) String channelId, String kafkaMessage) {
         try {
diff --git a/src/backend/state_server/src/main/java/com/jootalkpia/state_server/service/KafkaConsumer.java b/src/backend/state_server/src/main/java/com/jootalkpia/state_server/service/KafkaConsumer.java
@@ -22,7 +22,7 @@ public class KafkaConsumer {
     @KafkaListener(
             topics = "${topic.chat}",
             groupId = "${group.status}",
-            concurrency = "5"
+            concurrency = "8"
     )
     public void processState(String kafkaMessage) {
         ObjectMapper mapper = new ObjectMapper();

Original file line number	Diff line number	Diff line change
`@@ -41,7 +41,7 @@ public void processMinutePrice(String kafkaMessage) {`
`41`	`41`	`@KafkaListener(`
`42`	`42`	`topics = "${topic.chat}",`
`43`	`43`	`groupId = "${group.chat}",`
`44`		`- concurrency = "5"`
	`44`	`+ concurrency = "8"`
`45`	`45`	`)`
`46`	`46`	`public void processChatMessage(@Header(KafkaHeaders.RECEIVED_KEY) String channelId, String kafkaMessage) {`
`47`	`47`	`try {`
Original file line number	Diff line number	Diff line change
`@@ -22,7 +22,7 @@ public class KafkaConsumer {`
`22`	`22`	`@KafkaListener(`
`23`	`23`	`topics = "${topic.chat}",`
`24`	`24`	`groupId = "${group.status}",`
`25`		`- concurrency = "5"`
	`25`	`+ concurrency = "8"`
`26`	`26`	`)`
`27`	`27`	`public void processState(String kafkaMessage) {`
`28`	`28`	`ObjectMapper mapper = new ObjectMapper();`