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:

• GitHub Issues

License

KafkaFlow Retry is a free and open source project, released under the permissible MIT license.