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 target channel was successful; even with non-reactive binders (such as RabbitMQ, and the Kafka MessageChannel binder), the actual send is async. It won’t block.
It can only return false if the underlying channel is a type that can block, such as a QueueChannel with an upper bound of unprocessed messages (which is generally never the case, for any type of binder).