diff --git a/analytics-service/src/main/java/com/kt/event/analytics/config/KafkaConsumerConfig.java b/analytics-service/src/main/java/com/kt/event/analytics/config/KafkaConsumerConfig.java index 493a72d..8ffefb7 100644 --- a/analytics-service/src/main/java/com/kt/event/analytics/config/KafkaConsumerConfig.java +++ b/analytics-service/src/main/java/com/kt/event/analytics/config/KafkaConsumerConfig.java @@ -43,8 +43,8 @@ public class KafkaConsumerConfig { ConcurrentKafkaListenerContainerFactory factory = new ConcurrentKafkaListenerContainerFactory<>(); factory.setConsumerFactory(consumerFactory()); - // Kafka가 없어도 서비스가 시작되도록 자동 시작 비활성화 - factory.setAutoStartup(false); + // Kafka Consumer 자동 시작 활성화 + factory.setAutoStartup(true); return factory; } }