Advertisements Spring Team, The below producer is able to send the values to a kafka topic successfully. @Bean Supplier<Flux<Integer>> someProducer(){ return () -> Flux.range(1, 10); } But..how do we get the correlation id of the message produced as we get using ReactiveKafkaSender? Since the flux is subscribed by Spring internally, Is there any way to… Read More How to get correlation id in Spring Cloud Stream

Advertisements Spring Team, Is the Stream bridge safe to use along with Kafka ReactiveBinder? The below method returns a boolean. Not a Mono<Boolean>. Hence this question..! streambridge.send(…) The doc says, it returns true if the message was sent successfully. sounds like "blocking" >Solution : Yes, it’s safe. The result simply means that the send to… Read More StreamBridge with reactive binder