Moving from Reactive Programming to Reactive architecture: Reactive communication over RSocket

This article is the second in a three article series on moving from Reactive Programming to Reactive Architecture, where we take a look at using RSocket and RabbitMQ to handle Reactive Streams between different applications. In the first article of this series, we looked we looked at what an an architecture using reactive streams over … Continue reading "Moving from Reactive Programming to Reactive architecture: Reactive communication over RSocket"

Read More

Moving from Reactive Programming to Reactive architecture: An overview

This article is the first in a three article series on moving from Reactive Programming to Reactive Architecture, where we take a look at using RSocket and RabbitMQ to handle Reactive Streams between different applications. In this first article we’ll start with a high-level view of our three microservice applications that are integrated with each … Continue reading "Moving from Reactive Programming to Reactive architecture: An overview"

Read More

An introduction to Reactor Kafka

In An introduction to Apache Kafka we looked at Apache Kafka, a distributed streaming platform. This time we’ll be looking at Reactor Kafka, a library that enables the creation of Reactive Streams from Project Reactor to Kafka Topics and the other way around. Our sample applications We’ll be using two small sample applications, Paymentprocessor Gateway, and PaymentValidator. The code … Continue reading "An introduction to Reactor Kafka"

Read More

An introduction to Apache Kafka

The Reactive Manifesto states that responsive systems are resilient and elastic. One way to achieve this, is having our applications deployed multiple times next to each other. In case one instance goes down, there will be other ones to take up its task, adding more resilience to the system. In case more processing power is … Continue reading "An introduction to Apache Kafka"

Read More

Backpressure in Project Reactor: Saving your Subscribers from drowning

One of the main mechanisms behind Reactive Programming is backpressure. In this article we’ll take a look at the concept, and some of the advantages it creates when working with Reactive Streams. The concept of backpressure in Reactive Streams is as elegant as it is powerful. It will enable the use of slow Consumers within … Continue reading "Backpressure in Project Reactor: Saving your Subscribers from drowning"

Read More