spring-cloud-stream
spring-cloud-stream copied to clipboard
Add Transactional Support for Reactive Binder
This is a feature request for reactive binder.
We could provide transactional support for the following type.
@Bean
Function<Flux<Flux<T>>, Flux<Flux<R>>> transform(){
return outerFlux -> outerFlux
.map(innerFlux -> innerFlux.map(...));
}
then the innerFlux can be sent transactionally.
kafkaSender.sendTransactionally(..)
`