Merge pull request #213 from SKY-HORSE-MAN-POWER/refactor/#212

hotfix: kafka 설정 변경
3-RACEHORSE · Jun 27, 2024 · 806a0dc · 806a0dc
2 parents 56d171a + 843acbc
commit 806a0dc
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/src/main/java/com/leeforgiveness/memberservice/common/kafka/KafkaProducerConfig.java b/src/main/java/com/leeforgiveness/memberservice/common/kafka/KafkaProducerConfig.java
@@ -38,8 +38,6 @@ public KafkaTemplate<String, Object> kafkaTemplate() {
     @Bean
     public NewTopic chatTopic() {
         return TopicBuilder.name(Constant.SEND_TO_CHAT)
-            .partitions(2)
-            .replicas(2)
             .config(TopicConfig.RETENTION_MS_CONFIG, String.valueOf(86400000)) // 1일 (24시간) = 86400000 밀리초
             .build();
     }