(finalize-apache-config opts)Returns opts with final :ketu.apache.consumer/config entry
Returns opts with final :ketu.apache.consumer/config entry
(source ch opts)Starts consuming into a channel.
Returns a state map including out-chan. Pass it to the stop! function when done.
Starts consuming into a channel. Returns a state map including out-chan. Pass it to the `stop!` function when 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 |