From 1f0e42de4b538a44c6b9d504094827b3280d68e9 Mon Sep 17 00:00:00 2001
From: esmailian <esmailian.w@gmail.com>
Date: Mon, 28 Apr 2025 15:55:56 +0330
Subject: [PATCH] for test change kafka producer to single object after back to
 list of object in future

---
 .../testapp/kafkaProducerConfig/KafkaProducerConfig.java     | 5 +++--
 .../com/example/mmad/testapp/query/UserQueryHandler.java     | 4 ++--
 2 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/example/mmad/testapp/kafkaProducerConfig/KafkaProducerConfig.java b/src/main/java/com/example/mmad/testapp/kafkaProducerConfig/KafkaProducerConfig.java
index c1230bf..d3acd3c 100755
--- a/src/main/java/com/example/mmad/testapp/kafkaProducerConfig/KafkaProducerConfig.java
+++ b/src/main/java/com/example/mmad/testapp/kafkaProducerConfig/KafkaProducerConfig.java
@@ -1,5 +1,6 @@
 package com.example.mmad.testapp.kafkaProducerConfig;
 
+import com.example.mmad.testapp.event.UserCreatedEvent;
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.apache.kafka.common.serialization.StringSerializer;
 import org.springframework.context.annotation.Bean;
@@ -17,7 +18,7 @@ import java.util.Map;
 public class KafkaProducerConfig {
 
     @Bean
-    public ProducerFactory<String, List<?>> producerFactory() {
+    public ProducerFactory<String, UserCreatedEvent> producerFactory() {
         Map<String, Object> configProps = new HashMap<>();
         configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092"); // Replace with your Kafka broker address
         configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
@@ -26,7 +27,7 @@ public class KafkaProducerConfig {
     }
 
     @Bean
-    public KafkaTemplate<String, List<?>> kafkaTemplate() {
+    public KafkaTemplate<String, UserCreatedEvent> kafkaTemplate() {
         return new KafkaTemplate<>(producerFactory());
     }
 }
diff --git a/src/main/java/com/example/mmad/testapp/query/UserQueryHandler.java b/src/main/java/com/example/mmad/testapp/query/UserQueryHandler.java
index 097e4e2..b523a52 100644
--- a/src/main/java/com/example/mmad/testapp/query/UserQueryHandler.java
+++ b/src/main/java/com/example/mmad/testapp/query/UserQueryHandler.java
@@ -10,7 +10,7 @@ import java.util.List;
 
 @Component
 public class UserQueryHandler {
-    private static final String kafkaTopic = "user-commanded";
+    private static final String kafkaTopic = "user-created";
     private final KafkaProducerConfig kafkaProducer;
 
     public UserQueryHandler(KafkaProducerConfig kafkaProducer) {
@@ -20,7 +20,7 @@ public class UserQueryHandler {
     @Async("taskExecutor")
     @EventListener
     public void handelUserCreated(UserCreatedEvent event) {
-        kafkaProducer.kafkaTemplate().send(kafkaTopic, (List<?>) event);
+        kafkaProducer.kafkaTemplate().send(kafkaTopic, event);
         // persist in query data base
         System.out.println("Received user created event" + event.getUserId());
     }