(take-now bootstrap-servers topic decompress-fn)
(take-now bootstrap-servers topic decompress-fn timeout)
Reads whatever it can from a topic on the assumption that we've distributed work across multiple topics and another topic contained :done.
Reads whatever it can from a topic on the assumption that we've distributed work across multiple topics and another topic contained :done.
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 |