You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Expected behavior org.springframework.cloud.stream.binder.kafka.utils.BindingUtils#getConsumerMessageConverter is used to create a message converter (or any other way you prefer) to respect provided properties
The text was updated successfully, but these errors were encountered:
Describe the issue
spring-cloud-stream-binder-kafka-reactive ignores message converter configuration for producer message handler.
It just creates MessagingMessageConverter instance disrespecting user provided properties and beans.
See https://github.com/spring-cloud/spring-cloud-stream/blob/v4.0.4/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/main/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinder.java#L200
To Reproduce
Steps to reproduce the behavior:
spring.cloud.stream.kafka.binder.header-mapper-bean-name
Version of the framework
v4.0.4
Expected behavior
org.springframework.cloud.stream.binder.kafka.utils.BindingUtils#getConsumerMessageConverter
is used to create a message converter (or any other way you prefer) to respect provided propertiesThe text was updated successfully, but these errors were encountered: