(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 is a website building & hosting documentation for Clojure/Script libraries
× close