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

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 topic value)

(record topic key value)

(record topic partition key value)

(record topic partition timestamp key value headers)

send clj

(send producer record)

(send producer record call-back)