parallel-consumer
parallel-consumer copied to clipboard
confluentinc
Parallel Apache Kafka client wrapper with per message ACK, client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.
Description... ### Checklist - [ ] Documentation (if applicable) - [ ] Changelog Fixes: - #191 - #186 Blocked by: - #270 - #325
Fixes: - #314 Should this be done straight after #315 ? details in #314 - #315 - [ ] Documentation (if applicable) - [ ] Changelog Bassed on: - #315
Experiment: extend Consumer and Function - centralises documentation and makes usage more explicit This is a diverged fork of PR #268 - the relevant changes start from the commit titled:...
Description... - #299 Related: - https://github.com/bsideup/jabel/pull/144 ### Checklist - [ ] Documentation (if applicable) - [ ] Changelog
- [ ] convert output of some tests to use the new exception and check logging output is as expected - [ ] docs, including batch partial retry - [...
Description... ### Checklist - [ ] Documentation (if applicable) - [ ] Changelog
Implements - #205 May be overkill? - [ ] send read only messages
Metadata
Owner
Metadata
Parallel Apache Kafka client wrapper with per message ACK, client side queueing, a simpler consumer/producer API with key concurrency and extendable non-blocking IO processing.