Farfetch / kafkaflow-retry-extensions

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

WIP feat: support Kafka messages with nullable or empty partition key #87

Open sergioamribeiro opened 2 years ago

sergioamribeiro commented 2 years ago

Description

This merge request adds protection for the kafka messages that arrive without a value for the partition key (null or empty). The Retry will receive the messages and put them in the same queue and follow that order to process

Fixes # (10)

How Has This Been Tested?

We've made some unit and integration tests (see EmptyPartitionKeyRetryDurableTests class)

Checklist

Disclaimer

By sending us your contributions, you are agreeing that your contribution is made subject to the terms of our Contributor Ownership Statement