Show HN: Delayed Queue Using Kafka

3 points

2 years ago

We at Cashfree Payments Pvt Ltd are excited to introduce our Kafka Delayed Queue, a robust library designed for delayed message processing in Kafka, specifically tailored for Spring applications. This library leverages Kafka topics and scheduled tasks to efficiently manage and process delayed messages, ensuring high throughput and reliable message handling.

Our inspiration came from the fact that we were already using Kafka in one of our repo and the need for a delayed queue was forcing us to use another infrastructure compoenent. So, rather than integrating an additional infrastructure component, we decided to innovate and see if we could achieve delayed queue functionality directly within Kafka. To our delight, not only did we succeed, but we also achieved excellent performance.

Features: 1. Seamless Integration: Easily integrate with Spring applications.

2. Configurable Delays: Set customizable delay intervals for message processing.

3. High Throughput: Optimized for handling large volumes of messages.

4. Scalable and Reliable: Built on a robust architecture for scalability and reliability.

Prerequisites 1. Java: Version 8 or higher. 2. Apache Kafka: Version 2.0.0 or higher. 3. Spring Boot: Version 2.0 or higher.