refactor: 레플리카, 파티션 코드 삭제

3-RACEHORSE · Jun 27, 2024 · f32242b · f32242b
1 parent 648e250
commit f32242b
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/src/main/java/com/skyhorsemanpower/auction/kafka/KafkaProducerConfig.java b/src/main/java/com/skyhorsemanpower/auction/kafka/KafkaProducerConfig.java
@@ -38,17 +38,13 @@ public KafkaTemplate<String, Object> kafkaTemplate() {
     @Bean
     public NewTopic auctionCloseTopic() {
         return TopicBuilder.name(Topics.Constant.AUCTION_CLOSE)
-                .partitions(2)
-                .replicas(2)
                 .config(TopicConfig.RETENTION_MS_CONFIG, String.valueOf(172800000))
                 .build();
     }
 
     @Bean
     public NewTopic alarmTopic() {
         return TopicBuilder.name(Topics.Constant.ALARM)
-                .partitions(2)
-                .replicas(2)
                 .config(TopicConfig.RETENTION_MS_CONFIG, String.valueOf(172800000))
                 .build();
     }