Object değerleri için yeni ProducerFactory ve KafkaTemplate eklendi; hata yönetimi ve yeniden deneme ayarları güncellendi.

Author: omerada

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

@@ -12,6 +12,7 @@
 import org.springframework.kafka.core.ProducerFactory;
 import org.springframework.kafka.listener.CommonErrorHandler;
 import org.springframework.kafka.listener.DefaultErrorHandler;
+import org.springframework.kafka.support.serializer.JsonSerializer;
 import org.springframework.util.backoff.ExponentialBackOff;
 
 import java.util.HashMap;
@@ -53,6 +54,30 @@ public ProducerFactory<String, String> producerFactory() {
     public KafkaTemplate<String, String> kafkaTemplate() {
         return new KafkaTemplate<>(producerFactory());
     }
+    
+    // Object değerleri için yeni ProducerFactory
+    @Bean
+    public ProducerFactory<String, Object> objectProducerFactory() {
+        Map<String, Object> configProps = new HashMap<>();
+        configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
+        configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
+        configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class);
+        configProps.put(ProducerConfig.ACKS_CONFIG, "all");
+        configProps.put(ProducerConfig.RETRIES_CONFIG, 10);
+        configProps.put(ProducerConfig.RETRY_BACKOFF_MS_CONFIG, 1000);
+        configProps.put(ProducerConfig.RECONNECT_BACKOFF_MS_CONFIG, 1000);
+        configProps.put(ProducerConfig.RECONNECT_BACKOFF_MAX_MS_CONFIG, 5000);
+        configProps.put(ProducerConfig.MAX_BLOCK_MS_CONFIG, 10000);
+        configProps.put(ProducerConfig.DELIVERY_TIMEOUT_MS_CONFIG, 60000);
+        configProps.put(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG, 30000);
+        return new DefaultKafkaProducerFactory<>(configProps);
+    }
+    
+    // Object değerleri için KafkaTemplate
+    @Bean
+    public KafkaTemplate<String, Object> kafkaTemplateObject() {
+        return new KafkaTemplate<>(objectProducerFactory());
+    }
 
     @Bean
     public CommonErrorHandler errorHandler() {