Skip to content

Commit 15f7d04

Browse files
committed
test(be): 멀티 스레드 개수 증가
1 parent b3055c6 commit 15f7d04

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • src/backend/state_server/src/main/java/com/jootalkpia/state_server/service

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ public class KafkaConsumer {
2222
@KafkaListener(
2323
topics = "${topic.chat}",
2424
groupId = "${group.status}",
25-
concurrency = "5"
25+
concurrency = "8"
2626
)
2727
public void processState(String kafkaMessage) {
2828
ObjectMapper mapper = new ObjectMapper();

0 commit comments

Comments
 (0)