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 get?… Read More How to get correlation id in Spring Cloud Stream

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 the… Read More StreamBridge with reactive binder