From 806a6500b5c1bed945bd218b96e3bdb4df8a6d7e Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Tue, 7 Jun 2022 17:47:58 -0400 Subject: [PATCH] Kafka Streams binder message conversion changes Fixing boolean logic around non-native message conversion in Kafka Streams binder. --- .../kafka/streams/AbstractKafkaStreamsBinderProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java index b0158c921..50613fa79 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java @@ -492,7 +492,7 @@ public abstract class AbstractKafkaStreamsBinderProcessor implements Application stream = stream.mapValues((value) -> { Object returnValue; String contentType = bindingProperties.getContentType(); - if (value != null && !StringUtils.hasText(contentType)) { + if (value != null && StringUtils.hasText(contentType)) { final Headers headers = headersAtomicReference.get(); final Map headersMap = new HashMap<>(); headers.forEach(header -> headersMap.put(header.key(), header.value()));