Streams for reactive microservices
Spring Cloud Stream provides an abstraction over the messaging infrastructure. The underlying messaging implementation can be RabbitMQ, Redis, or Kafka. Spring Cloud Stream provides a declarative approach for sending and receiving messages:
As shown in the preceding diagram, Cloud Stream works on the concept of a source and a sink. The source represents the sender perspective of the messaging, and sink represents the receiver perspective of the messaging.
In the example shown in the diagram, the sender defines a logical queue called
Source.OUTPUT to which the sender sends messages. The receiver defines a logical ...