Showing content from https://github.com/Farfetch/kafkaflow-retry-extensions below:
Farfetch/kafkaflow-retry-extensions: Kafka Flow Retry Patterns Extensions
đ KafkaFlow Retry is an extension to KafkaFlow that implements resilience on Apache Kafka consumers.
Want to give it a try? Check out our Quickstart!
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
Read the docs for any further information.
Learn more about using KafkaFlow Retry Extensions here!
Read our contributing guidelines to learn about our development process, how to propose bugfixes and improvements, and how to build and test your changes.
You can find us at:
KafkaFlow Retry is a free and open source project, released under the permissible MIT license.
RetroSearch is an open source project built by @garambo
| Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4