diff --git a/analytics-service/src/main/java/com/posthub/analytics/config/KafkaConsumerConfig.java b/analytics-service/src/main/java/com/posthub/analytics/config/KafkaConsumerConfig.java
index bcf2f02..743da5e 100644
--- 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);