Skip to content

Farfetch/kafkaflow-retry-extensions

Repository files navigation

KafkaFlow Retry Extensions · GitHub license nuget version Build Main Codacy Badge

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

Get in touch

You can find us at:

License

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