From 2f9be858d76a3ba4f773e97f27125d3b0b36e86e Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Wed, 11 Dec 2024 13:08:41 +0100 Subject: [PATCH] GH-3055 Add additional types for toString() serialization Add additional types for toString() serialization to Kafka's to ensure propper serialization/deserialization of message header values. Resolves #3055 --- .../cloud/stream/binder/kafka/BinderHeaderMapper.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/BinderHeaderMapper.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/BinderHeaderMapper.java index 99dde2d1a..6161ba073 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/BinderHeaderMapper.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/BinderHeaderMapper.java @@ -92,7 +92,9 @@ public class BinderHeaderMapper extends AbstractKafkaHeaderMapper { private static final List DEFAULT_TO_STRING_CLASSES = Arrays.asList( "org.springframework.util.MimeType", - "org.springframework.http.MediaType" + "org.springframework.http.MediaType", + "java.time.OffsetDateTime", + "java.net.URI" ); /**