(make-consumer {:keys [key-deserializer value-deserializer kafka-configuration
topics]
:or {key-deserializer :edn value-deserializer :edn}})Create a consumer from a configuration
Create a consumer from a configuration
(reify-consumer-protocol consumer)Create a reified implementation of a consumer, which includes ConsumerProtocol and SharedProtocol functions
Create a reified implementation of a consumer, which includes ConsumerProtocol and SharedProtocol functions
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 |