test(be): 멀티스레드 개수 5로 증가

ki-met-hoon · ki-met-hoon · commit 473b54fb4e5b · 2025-04-11T01:32:08.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
@@ -59,7 +59,7 @@ public void processChatMessage(@Header(KafkaHeaders.RECEIVED_KEY) String channel
     @KafkaListener(
             topics = "${topic.push}",
             groupId = "${group.push}",
-            concurrency = "3"
+            concurrency = "5"
     )
     public void processPushMessage(String kafkaMessage) {
         log.info("message ===> " + kafkaMessage);

Original file line number	Diff line number	Diff line change
`@@ -59,7 +59,7 @@ public void processChatMessage(@Header(KafkaHeaders.RECEIVED_KEY) String channel`
`59`	`59`	`@KafkaListener(`
`60`	`60`	`topics = "${topic.push}",`
`61`	`61`	`groupId = "${group.push}",`
`62`		`- concurrency = "3"`
	`62`	`+ concurrency = "5"`
`63`	`63`	`)`
`64`	`64`	`public void processPushMessage(String kafkaMessage) {`
`65`	`65`	`log.info("message ===> " + kafkaMessage);`