kafka-clojure-client.producer — cn.leancloud/kafka-clojure-client 0.0.12

close clj

(close producer)

(close producer timeout time-unit)

create-kafka-producer clj

(create-kafka-producer configs)

(create-kafka-producer configs key-serializer value-serializer)

flush clj

(flush producer)

metrics clj

(metrics producer)

partitions-for-topic clj

(partitions-for-topic producer topic)

record clj

(record record)

send clj

(send producer record)

(send producer record call-back)