Note that it requires the message channel to be a `FluxMessageChannel`.
It currently only supports `Consumer<ReceiverRecord<?, ?>>` (no conversion).
The function binding should use the message channel directly instead of bridging
the direct channel to a reactive channel.
Producer Side PoC
Binder specific changes in ReactorKafkaBinder
Binder configuration
More changes to the reactive binder
Move KafkaBinderEnvironmentPostProcessor to the core module
Change binder key in spring.binders
Adding an e2e IT test for the reactive binder
Add lifecycle to integration adapters.
Remove unnecessary doStop().
Fix import order.
f3ccc7b72d