Skip to content

Commit

Permalink
Merge pull request #14 from surabhi-mahawar/hotflix-kafka-v-1
Browse files Browse the repository at this point in the history
kafka consumer without headers type
  • Loading branch information
ChakshuGautam authored Dec 13, 2021
2 parents e076596 + 103f9da commit c9ce4e6
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit c9ce4e6

Please sign in to comment.