Partitioning in message queues is a mechanism that divides topics or queues into multiple partitions. Each partition stores a portion of the data, and this data is processed in parallel. This makes receiving and processing messages faster and more efficient! Apache Kafka supports partitioning natively,… Read More

Spring Cloud Stream provides the spring-cloud-stream-test-binder dependency, allowing us to easily write unit tests for applications using Spring Cloud Stream without having to call actual message brokers. You can declare and use this spring-cloud-stream-test-binder dependency as follows:

I’ll use the example project from the… Read More

Spring Cloud Stream supports consumer routing, allowing us to decide which consumer will consume messages sent by a particular producer. We can route messages using message headers, payload content, or header content with expressions. Let’s explore this in detail in this tutorial! First, we’ll create… Read More

In the previous tutorial, I introduced you to Spring Cloud Stream with a binding mechanism that easily allows us to send and receive messages to any message broker automatically. If you want to send messages to a message broker manually, you can use Spring Cloud… Read More