Resilience Policies - Farfetch/kafkaflow-retry-extensions GitHub Wiki
| 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 wait, you want to keep processing next-in-line messages but you can't loss the current offset message. As persistance databases, MongoDb or SqlServer are available. And you can manage in-retry messages through HTTP API. | "I can't stop processing messages but I can't loss messages" | KafkaFlow.Retry KafkaFlow.Retry.API KafkaFlow.Retry.SqlServer or KafkaFlow.Retry.MongoDb |