Removed dependency in FunctioinConfiguration on BinderAwareChannelResolver
Improved StreamBridge to only register single pass-thru function to facilitate output type conversion
polish
Fixed logic which was creating an instance of every available binder configuration. This is primarily an issue for
Kafka Streams binder which as a module brings 3 different binder configurations - KTable, KStream, GlobalKTable.
Adding more log statements.
Resolves#1949
Given that ListenerContainerCustomizer is reggistered with the parent context and for multi-binder or binder environment customization such context is not set as a parent to binder context beans such as ListenerContainerCustomizer were not visible. This fix copies ListenerContainerCustomizer(s) from parent context to child context for such cases.
Resolves#1932
Given that StreamBridge is just a bridge and should honor whetever user sends through it, this fix ensures that message headers set by user are propagated
Resolves#1931
This way we ensure that only custom converters and converters defined by stream are included
effectively eliminating the possibility of other auto-configuration interfering with their converters
Resolves#1920
Ensured that when composing Function and Consumer no output binding is created. The initila fix was part of #1911 which addressed the reactive function/consumer combination. This fix does the same for imperative function/consumer combination
Resolves#1919
Currently the use of reactive EmitterProcessor is the only way to connect foreign sources such as HTTP with spring-cloud-stream
The newly added StreamBridgeUtils class provides a simpler mechanism to brideg non-stream application with stream application without requiring reactor API while also honoring the same type conversion and partitioning contract used by functions
Added docs
Resolves#1912
Address PR comments
Resolves#1918
Basically the Function<Flux, Mono<Void>> shoudl be treated as Consumer while allowing reference to the Flux so additional operations coudl be applied, but it will no longer result in creation of dummy output destination
Resolves#1911
