Liking cljdoc? Tell your friends :D
Clojure only.

kafka-clj-utils.producers

->producerclj

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

event-idclj

(event-id record)
source

publish-avro-bundleclj

(publish-avro-bundle k-producer bundle)
(publish-avro-bundle k-producer
                     ack-callback-fn
                     {:keys [avro-schema topic-name records key-fn]
                      :or {key-fn event-id}
                      :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 builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
←Move to previous article
→Move to next article
Ctrl+/Jump to the search field
Raise an issueBrowse cljdoc sourceChat on Slack
× close