Liking cljdoc? Tell your friends :D

kafka-clj-utils.producers


->producerclj

(->producer config)
(->producer kafka-config serde-config)
source

publish-avro-bundleclj

(publish-avro-bundle k-producer bundle)
(publish-avro-bundle k-producer
                     ack-callback-fn
                     {:keys [avro-schema topic-name records] :as _bundle})

Atomically produces an ::avro-bundle, throwing if any of the sends failed.

Atomically produces an ::avro-bundle, throwing if any of the sends failed.
sourceraw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close