KafkaFlow Retry Extensions · 
Introduction
🔁 KafkaFlow Retry is an extension to KafkaFlow that implements resilience on Apache Kafka consumers.
Want to give it a try? Check out our Quickstart!
Resilience policies
| Policy | Description | Aka | Required Packages |
|---|---|---|---|
| Simple Retry (policy family) (quickstart ; deep) |
Many faults are transient and may self-correct after a short delay. | "Maybe it's just a blip" | KafkaFlow.Retry |
| Forever Retry (policy family) (quickstart ; deep) |
Many faults are semi-transient and may self-correct after multiple retries. | "Never give up" | KafkaFlow.Retry |
| Durable Retry (quickstart ; deep) |
Beyond a certain amount of retries and waiting, you want to keep processing next-in-line messages but you can't lose the current offset message. As persistence databases, MongoDb, Postgres or SqlServer is available. And you can manage in-retry messages through HTTP API. | "I can't stop processing messages but I can't lose messages" | KafkaFlow.Retry KafkaFlow.Retry.API KafkaFlow.Retry.SqlServer or KafkaFlow.Retry.Postgres or KafkaFlow.Retry.MongoDb |
Installation
Read the docs for any further information.
Documentation
Learn more about using KafkaFlow Retry Extensions here!
Contributing
Read our contributing guidelines to learn about our development process, how to propose bugfixes and improvements, and how to build and test your changes.
Maintainers
- Bruno Gomes
- Carlos Miranda
- Fernando Marins
- Leandro Magalhães
- Luís Garcês
- Martinho Novais
- Rodrigo Belo
- Sérgio Ribeiro
Get in touch
You can find us at:
License
KafkaFlow Retry is a free and open source project, released under the permissible MIT license.