Antony Stubbs
Antony Stubbs
Experimentation here https://github.com/confluentinc/parallel-consumer/pull/179
https://github.com/release-drafter/release-drafter
Use a central cache to share rate limit info amongst processing cluster, to implement coordination of rate limit exhaustion to prevent accidental overrun while effectively exhausting the available credits. https://dzone.com/articles/introduction-jcache-jsr-107...
Add API support into reactor.io module for JDK's standard [CompletableFuture](https://docs.oracle.com/en/java/javase/17/docs/api/java.base/java/util/concurrent/CompletableFuture.html) using same technique as distributed rate limiting example's integration with BucketJ in [this diff](https://github.com/confluentinc/parallel-consumer/compare/master...astubbs:features/rate-limiting#diff-9e6185103da281ca730d012e8c67ca198d099f103a60c62ce81dc7ad5a751275R81). - [ ] Add as convenience...
Embed into rest proxy, and have clients request messages to process, with the concurrency and committing handled as per usual by PC. This enables the PC to be used from...
ProducerManager#commitOffsets handles all TX commit failures the same - it just retries. This is wishful thinking, and we should treat each failure properly - either by giving up faster, shutting...
consider trialing GitHub actions and getting Travis working again
Having the ability to only process a message at a certain time, say for scheduling sending messages to users. This could be quite easily achieved by extending the existing retry...