waterdrop
waterdrop copied to clipboard
Standalone Karafka library for producing Kafka messages
We should be able to have a throttle setting where we define max number of messages we can have in "async sending" beyond which things should be throttled until a...
- Uses Kafka itself for the Quorum Controller - see: https://developer.confluent.io/learn/kraft/ - Switch to the much more up to date Bitnami Kafka Image - up to Kafka 3.1 (wurstmeister is...
- [ ] encrypt payload - [ ] encrypt headers We can encrypt headers by taking all of them and transforming them into a single header key and having e...
There are no breaking changes here: https://my.diffend.io/gems/rdkafka/0.13.0.beta.1/0.13.0.beta.2 we can easily transition and require it. Thanks to that we can remove some checks, etc.
This issue lists Renovate updates and detected dependencies. Read the [Dependency Dashboard](https://docs.renovatebot.com/key-concepts/dashboard/) docs to learn more.[View this repository on the Mend.io Web Portal](https://developer.mend.io/github/karafka/waterdrop). ## Ignored or Blocked These are blocked...
Such a partitioner should respond to `#call` and should be given two things: 1. Topic name 2. Current partitions count In case it returns `false` it should just not inject...