change log | getting started | documentation
In (mostly) every kafka consumer we use in our pipeline, the same guarantees are needed: do not move forward until record is successfully consumed (handled without exception), infinitely retry to process failed records and automatically recover. In consequence, we want to manage and commit offsets manually. That's why this abstraction over java consumer API was written.
Add dependency to project.clj
:
See getting started for more info.
Can you improve this documentation?Edit on GitHub
cljdoc builds & hosts documentation for Clojure/Script libraries
Ctrl+k | Jump to recent docs |
← | Move to previous article |
→ | Move to next article |
Ctrl+/ | Jump to the search field |