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

->producer clj

(->producer config)

(->producer kafka-config serde-config)

event-id clj

(event-id record)

publish-avro-bundle clj

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