send! (commit)0.1.3=> (def p (g/producer (get-in config [:kafka :producer])))
;; send a couple of messages to topics: "foos" and "bars"
=> (g/send! p "foos" "{:answer 42}")
=> (g/send! p "bars" "{:answer 42}")
=> (g/close p)
0.1.3grete/producer returned a map of {:producer .. :topic ..}:
=> (def p (g/producer "foos" (get-in config [:kafka :producer])))
=> (g/send! p "{:answer 42}")
=> (g/send! p "{:answer 42}")
=> (g/close p)
Can you improve this documentation? These fine people already did:
anatoly & AnatolyEdit 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 |