move serializers/deserializers to serdes package

payments-producer/src/main/java/com/redhat/training/kafka/coreapi/ProducerApp.java

@@ -53,7 +53,7 @@ public class ProducerApp {
         props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
                 org.apache.kafka.common.serialization.StringSerializer.class.getName());
         props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
-                com.redhat.training.kafka.serde.BankAccountSerializer.class.getName());
+                com.redhat.training.kafka.serdes.BankAccountSerializer.class.getName());
         return props;
     }
     public static Properties configureRiskProperties() {
@@ -61,7 +61,7 @@ public class ProducerApp {
         props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
                 org.apache.kafka.common.serialization.StringSerializer.class.getName());
         props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
-                com.redhat.training.kafka.serde.RiskAssessmentSerializer.class.getName());
+                com.redhat.training.kafka.serdes.RiskAssessmentSerializer.class.getName());
         return props;
     }
     public static Properties configurePaymentProperties() {
@@ -76,6 +76,7 @@ public class ProducerApp {
     public static void main(String[] args) throws Exception {
         Random random = new Random();
 
+        // 
         if (System.getProperty("initialize.accounts") != null &&
                 System.getProperty("initialize.accounts").equals("true")) {
             LOG.info("Initializing account data...");

payments-producer/src/main/java/com/redhat/training/kafka/serde/BankAccountSerializer.java → payments-producer/src/main/java/com/redhat/training/kafka/serdes/BankAccountSerializer.java

@@ -1,4 +1,4 @@
-package com.redhat.training.kafka.serde;
+package com.redhat.training.kafka.serdes;
 
 import org.apache.kafka.common.serialization.Serializer;
 

payments-producer/src/main/java/com/redhat/training/kafka/serde/RiskAssessmentSerializer.java → payments-producer/src/main/java/com/redhat/training/kafka/serdes/RiskAssessmentSerializer.java

@@ -1,4 +1,4 @@
-package com.redhat.training.kafka.serde;
+package com.redhat.training.kafka.serdes;
 
 import org.apache.kafka.common.serialization.Serializer;
 

quarkus-weather-consumer/src/main/java/com/redhat/training/kafka/model/WeatherObjectDeserializer.java → quarkus-weather-consumer/src/main/java/com/redhat/training/kafka/serdes/WeatherObjectDeserializer.java

@@ -1,4 +1,6 @@
-package com.redhat.training.kafka.model;
+package com.redhat.training.kafka.serdes;
+
+import com.redhat.training.kafka.model.Weather;
 
 import io.quarkus.kafka.client.serialization.ObjectMapperDeserializer;
 

quarkus-weather-consumer/src/main/resources/application.properties

@@ -27,7 +27,7 @@ mp.messaging.incoming.weather-forecast.kafka-configuration = quarkus-consumer-co
 # mp.messaging.incoming.weather-forecast.dead-letter-queue.value.serializer =
 
 mp.messaging.incoming.weather-forecast.key.deserializer = org.apache.kafka.common.serialization.StringDeserializer
-mp.messaging.incoming.weather-forecast.value.deserializer = com.redhat.training.kafka.model.WeatherObjectDeserializer
+mp.messaging.incoming.weather-forecast.value.deserializer = com.redhat.training.kafka.serdes.WeatherObjectDeserializer
 
 # AVRO & schema registry
 # mp.messaging.incoming.weather-forecast.value.deserializer=io.apicurio.registry.utils.serde.AvroKafkaDeserializer

weather-consumer/src/main/java/com/redhat/training/kafka/coreapi/ConsumerApp.java

@@ -44,7 +44,7 @@ public class ConsumerApp
         props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
                      org.apache.kafka.common.serialization.VoidDeserializer.class.getName());
         props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
-                        com.redhat.training.kafka.model.WeatherDeserializer.class.getName());
+                        com.redhat.training.kafka.serdes.WeatherDeserializer.class.getName());
         // props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, false);
         // props.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, 500);
 

weather-consumer/src/main/java/com/redhat/training/kafka/model/WeatherDeserializer.java → weather-consumer/src/main/java/com/redhat/training/kafka/serdes/WeatherDeserializer.java

@@ -1,8 +1,9 @@
-package com.redhat.training.kafka.model;
+package com.redhat.training.kafka.serdes;
 
 import org.apache.kafka.common.serialization.Deserializer;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.redhat.training.kafka.model.Weather;
 
 public class WeatherDeserializer implements Deserializer<Weather> {
     private ObjectMapper om = new ObjectMapper();

weather-producer/src/main/java/com/redhat/training/kafka/coreapi/ProducerApp.java

@@ -30,7 +30,7 @@ public class ProducerApp {
         props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
                     org.apache.kafka.common.serialization.VoidSerializer.class.getName());
         props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,
-                    com.redhat.training.kafka.model.WeatherSerializer.class.getName());
+                    com.redhat.training.kafka.serdes.WeatherSerializer.class.getName());
 
         // configure the SSL connection (if necessary)
         // props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SSL");

weather-producer/src/main/java/com/redhat/training/kafka/model/WeatherSerializer.java → weather-producer/src/main/java/com/redhat/training/kafka/serdes/WeatherSerializer.java

@@ -1,9 +1,10 @@
-package com.redhat.training.kafka.model;
+package com.redhat.training.kafka.serdes;
 
 import org.apache.kafka.common.serialization.Serializer;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.redhat.training.kafka.model.Weather;
 
 public class WeatherSerializer implements Serializer<Weather> {
     private ObjectMapper om = new ObjectMapper();