diff --git a/app/src/main/java/org/javadev/kafkaexample/config/KafkaConsumerConfig.java b/app/src/main/java/org/javadev/kafkaexample/config/KafkaConsumerConfig.java
index 259940f..21711f9 100644
--- a/app/src/main/java/org/javadev/kafkaexample/config/KafkaConsumerConfig.java
+++ b/app/src/main/java/org/javadev/kafkaexample/config/KafkaConsumerConfig.java
@@ -37,7 +37,7 @@ public class KafkaConsumerConfig {
         return new DefaultKafkaConsumerFactory<>(
                 consumerConfig(),
                 new StringDeserializer(),
-                new JsonDeserializer<>()
+                jsonDeserializer
         );
     }