From 96781b65bcb3945476866a7441a8d1c9de39aca1 Mon Sep 17 00:00:00 2001 From: Marius Bogoevici Date: Thu, 25 Aug 2016 08:25:30 -0400 Subject: [PATCH] Add deserializer to health indicator configuration Fixes #17 --- .../cloud/stream/binder/kafka/KafkaBinderHealthIndicator.java | 1 + 1 file changed, 1 insertion(+) diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicator.java b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicator.java index eba4a0bcb..64a09ad1a 100644 --- a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicator.java +++ b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaBinderHealthIndicator.java @@ -55,6 +55,7 @@ public class KafkaBinderHealthIndicator implements HealthIndicator { properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, this.configurationProperties .getKafkaConnectionString()); properties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, ByteArrayDeserializer.class.getName()); + properties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, ByteArrayDeserializer.class.getName()); KafkaConsumer metadataConsumer = new KafkaConsumer(properties); try { Set downMessages = new HashSet<>();