Soby Chacko

@iozho Thank you for your quick response. We will go ahead and close this issue. Feel free to re-open if there is a need or any issues.

As described above, one workaround is to set the `app.processor.spring.cloud.stream.bindings.output.producer.partition-count` to the updated partition count. However, if you are using Spring Cloud Stream `4.0.3` or later, we recommend instead setting...

@LiquidSelf, Could you put these components in a sample project and share with us? We can then triage the issue further to identify the issue.

Should we add a small docs section pointing to the upstream feature?

@dkumarkartik @EmperorBlack Could you share your config/code here? Also, how can we reproduce it on our end? Which schema registry are you using? Confluent or the one from Spring Cloud...

@ThiemoFischer Looking forward to any feedback and suggestions for this binder.

Closing this issue now as the reactive Kafka binder is implemented as part of Spring Cloud Stream `4.0.0`. Feel free to create new feature requests, bug reports, etc. for the...

@voodemsanthosh You can produce/consume headers by switching your outgoing/incoming type to `Message` instead. Here are two functions for example. ``` @Bean public Supplier supplier() { return () -> MessageBuilder.withPayload("hello").setHeader("foo", "bar").build();...

@metalpalo Apologies for not getting back to you for a long time. We no longer need to set `embeddedHeaders` since Apache Kafka provides native headers support. This is intended for...

We now have support for Apache Pulsar in the Spring portfolio. Here is the core library: https://github.com/spring-projects/spring-pulsar Spring Cloud Stream Pulsar binder: https://github.com/spring-cloud/spring-cloud-stream/tree/main/binders/pulsar-binder Any feedback is appreciated. Thank you!