[Fix] Add concurrency setting

teamWaggle · Oct 28, 2024 · b058c4f · b058c4f
1 parent 66e25fd
commit b058c4f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/src/main/java/com/example/waggle/global/config/kafka/KafkaConsumerConfig.java b/src/main/java/com/example/waggle/global/config/kafka/KafkaConsumerConfig.java
@@ -12,6 +12,7 @@
 import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
 import org.springframework.kafka.core.ConsumerFactory;
 import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
+import org.springframework.kafka.listener.ContainerProperties;
 import org.springframework.kafka.support.serializer.JsonDeserializer;
 
 import java.util.Map;
@@ -27,6 +28,8 @@ public class KafkaConsumerConfig {
     ConcurrentKafkaListenerContainerFactory<String, ChatMessageDto> kafkaListenerContainerFactory() {
         ConcurrentKafkaListenerContainerFactory<String, ChatMessageDto> factory = new ConcurrentKafkaListenerContainerFactory<>();
         factory.setConsumerFactory(consumerFactory());
+        factory.setConcurrency(6);  // 파티션 개수에 맞춰 스레드 설정
+        factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL);  // 수동 커밋 모드
         return factory;
     }
 

diff --git a/src/main/java/com/example/waggle/security/jwt/service/TokenServiceImpl.java b/src/main/java/com/example/waggle/security/jwt/service/TokenServiceImpl.java
@@ -133,7 +133,7 @@ public JwtToken generateToken(Authentication authentication) {
                 .grantType("Bearer")
                 .accessToken(accessToken)
                 .refreshToken(refreshToken)
-                .build();
+                .build();User
     }
 
     @Override