NG

diff --git a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java
index 4f6e918bea8c604521387a0fb579d7778a04bccc..af8c0aad6a7de1c5526983b3a32e7ec7d2c231a1 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/persistence/kafka/KafkaServicesConfiguration.java
@@ -109,11 +109,11 @@ public class KafkaServicesConfiguration
   }
 
   @Bean
-  Consumer<String, ChatMessageTo>  chatMessageChannelConsumer(
+  Consumer<String, AbstractTo>  chatMessageChannelConsumer(
       Properties defaultConsumerProperties,
       ChatBackendProperties chatBackendProperties,
       StringDeserializer stringDeserializer,
-      JsonDeserializer<ChatMessageTo> messageDeserializer)
+      JsonDeserializer<AbstractTo> messageDeserializer)
   {
     Map<String, Object> properties = new HashMap<>();
     defaultConsumerProperties.forEach((key, value) -> properties.put(key.toString(), value));
@@ -136,14 +136,11 @@ public class KafkaServicesConfiguration
   }
 
   @Bean
-  JsonDeserializer<ChatMessageTo> chatMessageDeserializer()
+  JsonDeserializer<AbstractTo> chatMessageDeserializer()
   {
-    JsonDeserializer<ChatMessageTo> deserializer = new JsonDeserializer<>();
+    JsonDeserializer<AbstractTo> deserializer = new JsonDeserializer<>();
     deserializer.configure(
-        Map.of(
-            JsonDeserializer.USE_TYPE_INFO_HEADERS, false,
-            JsonDeserializer.VALUE_DEFAULT_TYPE, ChatMessageTo.class,
-            JsonDeserializer.TRUSTED_PACKAGES, getClass().getPackageName()),
+        Map.of(JsonDeserializer.TRUSTED_PACKAGES, getClass().getPackageName()),
         false );
     return deserializer;
   }