spring-cloud-stream icon indicating copy to clipboard operation
spring-cloud-stream copied to clipboard

Add Transactional Support for Reactive Binder

Open kitkars opened this issue 2 years ago • 0 comments

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(..) `

kitkars avatar Apr 04 '23 23:04 kitkars