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.3
grete/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 |