Farfetch / kafkaflow-retry-extensions

Kafka Flow Retry Patterns Extensions
https://farfetch.github.io/kafkaflow-retry-extensions/
MIT License
56 stars 7 forks source link

Strategy to rotate the retry queues #57

Closed rodrigobelo closed 1 year ago

rodrigobelo commented 2 years ago

Is your request related to a problem you have?

Allow defining a sliding strategy that always orders by last execution.

As default currently, we always execute the top 1024 queues. The idea is to have a constantly changing list of execution (on rotation).

Describe the solution you'd like

In order to accomplish this, we can order the retrieved queues by last execution date, to ensure the older retried queues are executed first.

Are you able to help bring it to life and contribute with a Pull Request?

Yes

Additional context

No response

luispfgarces commented 1 year ago

As confirmed by @fernando-a-marins, this is already implemented and ensured by the KafkaFlow Retry extension.