(consumer! {:keys [topic properties duration] :or {duration 100}})Receives a map of a topic and the japa properties. Returns a channel that will be populated as a message is received in the kafka poll in a different thread.
Receives a map of a topic and the japa properties. Returns a channel that will be populated as a message is received in the kafka poll in a different thread.
(producer! {:keys [topic properties flush?] :or {flush? true}})Receives a map of a topic and the japa properties. Returns a channel that will be consumed and sent each individual message to kafka in a different thread.
Receives a map of a topic and the japa properties. Returns a channel that will be consumed and sent each individual message to kafka in a different thread.
(worker! channel f)Execute a function f each time a message is received at the channel. Checks if a exception is passed in a channel, if it is f will not be applied and the exception will be logged.
Execute a function f each time a message is received at the channel. Checks if a exception is passed in a channel, if it is f will not be applied and the exception will be logged.
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 |