feat(kafka): Kafka yapılandırması güncellendi ve log seviyeleri iyileştirildi

Author: omerada

user-service/src/main/java/com/craftpilot/userservice/config/KafkaConfig.java

@@ -25,6 +25,7 @@
 
 @Configuration
 @Slf4j
+@ConditionalOnProperty(name = "kafka.enabled", havingValue = "true", matchIfMissing = true)
 public class KafkaConfig {
 
     @Value("${spring.kafka.bootstrap-servers:kafka:9092}")
@@ -34,7 +35,7 @@ public class KafkaConfig {
     private boolean kafkaEnabled;
 
     @Bean
-    @ConditionalOnProperty(name = "spring.kafka.enabled", havingValue = "true", matchIfMissing = true)
+    @ConditionalOnProperty(name = "kafka.enabled", havingValue = "true", matchIfMissing = true)
     public ProducerFactory<String, Object> producerFactory() {
         Map<String, Object> configProps = new HashMap<>();
         configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
@@ -50,7 +51,7 @@ public ProducerFactory<String, Object> producerFactory() {
     }
 
     @Bean
-    @ConditionalOnProperty(name = "spring.kafka.enabled", havingValue = "true", matchIfMissing = true)
+    @ConditionalOnProperty(name = "kafka.enabled", havingValue = "true", matchIfMissing = true)
     public KafkaTemplate<String, Object> kafkaTemplate() {
         try {
             return new KafkaTemplate<>(producerFactory());
@@ -62,7 +63,7 @@ public KafkaTemplate<String, Object> kafkaTemplate() {
     }
 
     @Bean
-    @ConditionalOnProperty(name = "spring.kafka.enabled", havingValue = "true", matchIfMissing = true)
+    @ConditionalOnProperty(name = "kafka.enabled", havingValue = "true", matchIfMissing = true)
     public KafkaAdmin kafkaAdmin() {
         Map<String, Object> configs = new HashMap<>();
         configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);

user-service/src/main/java/com/craftpilot/userservice/service/UserPreferenceService.java

@@ -27,7 +27,7 @@ public class UserPreferenceService {
     private final EventService eventService;
     private final KafkaTemplate<String, UserPreferenceEvent> kafkaTemplate;
 
-    @Value("${spring.kafka.enabled:true}")
+    @Value("${kafka.enabled:true}")
     private boolean kafkaEnabled;
 
     @Value("${spring.kafka.topic.user-preferences:user-preferences}")

user-service/src/main/resources/application.yml

@@ -38,16 +38,13 @@ spring:
     commons:
       logging:
         level: WARN
-  # Kafka konfigürasyonu (kafka-base.yml'de temel ayarlar tanımlanmış)
+  # Kafka konfigürasyonu - kafka-base.yml'den import ediliyor
   kafka:
-    enabled: ${KAFKA_ENABLED:true}
     bootstrap-servers: ${KAFKA_BOOTSTRAP_SERVERS:localhost:9092}
-    topic:
-      user-preferences: ${KAFKA_TOPIC_USER_PREFERENCES:user-preferences}
-      user-events: ${KAFKA_TOPIC_USER_EVENTS:user-events}
-      activity-events: ${KAFKA_TOPIC_ACTIVITY_EVENTS:activity-events}
 
+# Kafka spesifik ayarları ayrı bir namespace'te tanımla
 kafka:
+  enabled: ${KAFKA_ENABLED:true}
   topics:
     user-events: ${KAFKA_TOPIC_USER_EVENTS:user-events}
     user-preferences: ${KAFKA_TOPIC_USER_PREFERENCES:user-preferences}

user-service/src/main/resources/logback-spring.xml

@@ -54,7 +54,10 @@
     <!-- Diğer paket düzeyinde loglar -->
     <logger name="org.springframework.data.mongodb" level="WARN" />
     <logger name="org.springframework.data.redis" level="WARN" />
-    <logger name="org.springframework.kafka" level="WARN" />
+    <logger name="org.springframework.kafka" level="INFO" />
+    <logger name="org.springframework.kafka.config" level="DEBUG" />
+    <logger name="org.springframework.kafka.core" level="DEBUG" />
+    <logger name="com.craftpilot.userservice.config" level="DEBUG" />
     <logger name="io.lettuce" level="WARN" />
     <logger name="io.netty" level="WARN" />
     <logger name="org.apache.kafka" level="WARN" />