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
Reactive Kafka binder currently does not look at this header. Spring for Apache Kafka added support for custom partition headers in the MessagingMessageConverter which should be used from the binder.
The text was updated successfully, but these errors were encountered:
Spring Cloud Stream adds its own header for binder supported partition. https://github.com/spring-cloud/spring-cloud-stream/blob/main/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/BinderHeaders.java#L61
Reactive Kafka binder currently does not look at this header. Spring for Apache Kafka added support for custom partition headers in the
MessagingMessageConverter
which should be used from the binder.The text was updated successfully, but these errors were encountered: