kafka-clj.apputils.cmd-produce — kafka-clj 4.0.3

App produce command

as-int clj

(as-int v)

generate-test-message clj

(generate-test-message i)

mean clj

(mean coll)

rand-str clj

(rand-str len)

https://gist.github.com/rboyd/5053955

send-data clj

(send-data threads count-per-thread topic brokers conf)

{:message-stats {:times [] :totals []} :errors num}

send-test-data clj

(send-test-data threads count-per-thread topic brokers conf)

brokers : [{:host :port} ... ]

update-message-stats! clj

(update-message-stats! messages-stats start-ts count-per-thread)