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" ); /**