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

ki-met-hoon · ki-met-hoon · commit 13d6b8db777e · 2025-04-13T01:12:50.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
@@ -40,7 +40,8 @@ public void processMinutePrice(String kafkaMessage) {
 
     @KafkaListener(
             topics = "${topic.chat}",
-            groupId = "${group.chat}"
+            groupId = "${group.chat}",
+            concurrency = "5"
     )
     public void processChatMessage(@Header(KafkaHeaders.RECEIVED_KEY) String channelId, String kafkaMessage) {
         try {

Original file line number	Diff line number	Diff line change
`@@ -40,7 +40,8 @@ public void processMinutePrice(String kafkaMessage) {`
`40`	`40`
`41`	`41`	`@KafkaListener(`
`42`	`42`	`topics = "${topic.chat}",`
`43`		`- groupId = "${group.chat}"`
	`43`	`+ groupId = "${group.chat}",`
	`44`	`+ concurrency = "5"`
`44`	`45`	`)`
`45`	`46`	`public void processChatMessage(@Header(KafkaHeaders.RECEIVED_KEY) String channelId, String kafkaMessage) {`
`46`	`47`	`try {`