Spring Cloud Stream

Retry is an essential part of microservices which has a lot to handle on their plate. Spring Cloud Stream is in our lives for a couple of years, wiring message brokers like Kafka, and RabbitMQ. In this article, I will explain how to handle Kafka consumer retry in Spring Cloud…

With the increase in demand for real-time processing of data, a lot of developers are building and dealing with streaming data. Kafka has proved to be one of the most widely used tools present in the market that can process millions of records without much hassle. Kafka provides Kafka Streams…

Spring is one of the most widely used Java Frameworks to develop Cloud-Native Applications. Kafka is one of the most famous message brokers out there. Therefore there is a high probability that you may end up using Spring Cloud Streams Kafka Streams Binder (or we can use KStream Binder). When…

Spring Cloud Stream is a framework/module for building highly scalable event-driven microservices connected with shared messaging systems. Event-driven — It's nothing but a sharing of messages (data) in the form of events. Suppose we have a small product delivery systems architecture . Refer below image.

This story aims to provide a simple implementation on how functional approach is used for binding Azure Service Bus topics to our microservice consumer and publisher. Following are the assumptions prior to stitching each components: Resource groups are created Primary connection string is created Topics are already defined It would…

In this article, we will be looking into how we can communicate with Kafka Cluster using Spring Cloud Stream. Introduction Spring Cloud Stream, is a mechanism by which you can decouple the implementation of your producers and consumers from the type of messaging infrastructure you want to use. …

Recently, I was working on Kafka. Client had a requirement to process all the messages received in every 15 minutes, The main intention was to reduce the number of calls to a database. First thought came in mind was, if there is a batching supported in spring cloud streams. Batch…

Spring cloud stream with functional programming. — Introduction This story talks about using spring cloud stream and building binder agnostic event application using spring boot with functional programming. You might have used annotations while using spring cloud to define bindings channels[INPUT/OUTPUT], stream listeners which is now deprecated, I will not go into details of that but will mainly…