I want to define a flow that writes to MongoDB, and only on success writes the IDs to Kafka. I'm using the JavaDSL, and I'd wish to have a FlowBuilder class that defines my pipeline at a high level. I...

I have a simple Spring controller which have a Spring service as dependency. In the service class I have a static volatile field of type int called flag. When I invoke createFlux() method through my c...

During unit testing retry the response of the mock seems cached, or most probably I am doing something wrong. I am trying to request something, if error happened then retry twice with delay of 1 secon...

I’m using Project Reactor for a non-blocking IO data pipeline, and I’m thinking of using Spring Integration as an abstraction layer to manage all of the flows and components in my pipeline. I’m curren...