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

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

Flux Caching in Project Reactor: Replaying past data

In the article Flux Sharing in Project Reactor: From one to many we looked at how we can attach multiple Fluxes to an initial Flux by sharing it, to create multiple substreams from our original Reactive stream. This offers quite a bit of extra power. We can “feed” data to different subsystems that can consume … Continue reading "Flux Caching in Project Reactor: Replaying past data"

Read More

Flux Sharing in Project Reactor: From one to many

Reactive Applications often require Reactive Streams to be subscribed to by multiple Subscribers at the same time. For example when the same information streams needs to be used by different components in the application, or when we want to let the data stream to different users. Especially in real-time applications this can be a huge … Continue reading "Flux Sharing in Project Reactor: From one to many"

Read More

TopicProcessor in Project Reactor: Spreading the message to many

When building your Reactive Application, you sometimes want to split up your single stream into several ones, running concurrently. One of the ways this can be done using the TopicProcessor. Very similary to the concept of a Topic seen in JMS, a TopicProcessor can be used to subscribe on one or multiple streams, and have … Continue reading "TopicProcessor in Project Reactor: Spreading the message to many"

Read More