kafka-clj-utils.producers — ovotech/kafka-clj-utils 2.1.0-3

->producer clj

(->producer config)

(->producer kafka-config serde-config)

publish-avro-bundle clj

(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.