SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Kafka Streams binder message conversion changes

Browse Source 
Fixing boolean logic around non-native message conversion in Kafka Streams binder.
This commit is contained in:
Soby Chacko
2022-06-07 17:47:58 -04:00
parent cc28eb7c6b
commit 806a6500b5
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/AbstractKafkaStreamsBinderProcessor.java
View File

@@ -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<String, Object> headersMap = new HashMap<>();
headers.forEach(header -> headersMap.put(header.key(), header.value()));