kafka

2026-02-27 05:05:24 +01:00
parent cdcdf97894
commit ee405e78e6
1 changed files with 1 additions and 0 deletions
--- a/analytics-service/src/main/java/com/posthub/analytics/config/KafkaConsumerConfig.java
+++ b/analytics-service/src/main/java/com/posthub/analytics/config/KafkaConsumerConfig.java
@@ -31,6 +31,7 @@ public class KafkaConsumerConfig {
        jsonDeserializer.setRemoveTypeHeaders(true);
        jsonDeserializer.addTrustedPackages("*");
        jsonDeserializer.setUseTypeMapperForKey(false);
+        jsonDeserializer.setUseTypeHeaders(false);

        ErrorHandlingDeserializer<UserEvent> errorHandlingDeserializer =
                new ErrorHandlingDeserializer<>(jsonDeserializer);