diff --git a/src/main/java/com/uci/outbound/Application/ReactiveKafkaConfiguration.java b/src/main/java/com/uci/outbound/Application/ReactiveKafkaConfiguration.java
index 091afbb..d533953 100644
--- a/src/main/java/com/uci/outbound/Application/ReactiveKafkaConfiguration.java
+++ b/src/main/java/com/uci/outbound/Application/ReactiveKafkaConfiguration.java
@@ -39,7 +39,7 @@ ReceiverOptions<String, String> kafkaReceiverOptions(@Value("${outbound}") Strin
         ReceiverOptions<String, String> options = ReceiverOptions.create(kafkaConsumerConfiguration());
         return options.subscription(Arrays.asList(inTopicName))
                 .withKeyDeserializer(new JsonDeserializer<>())
-                .withValueDeserializer(new JsonDeserializer());
+                .withValueDeserializer(new JsonDeserializer(String.class));
     }
 
     @Bean