From 103f9da77041405a92cac61fd4cfe63d20894ff6 Mon Sep 17 00:00:00 2001
From: Surabhi <surabhi.mahawar@aurigait.com>
Date: Tue, 7 Dec 2021 11:06:15 +0530
Subject: [PATCH] kafka consumer headers type - changes for kafka 1

---
 .../uci/outbound/Application/ReactiveKafkaConfiguration.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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