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

close clj

(close producer)

(close producer timeout time-unit)

Close a Kafka producer

create-kafka-producer clj

(create-kafka-producer configs)

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

Create a Kafka producer with configurations and serializers

flush clj

(flush producer)

metrics clj

(metrics producer)

partitions-for-topic clj

(partitions-for-topic producer topic)

record clj

(record record)

Convert a map to ProducerRecord.

send clj

(send producer record-map)

(send producer record-map call-back)

Send a Map which can be converted to ProducerRecord by calling function "record" with a producer.

send-record clj

(send-record producer record)

(send-record producer record call-back)

Send a ProducerRecord with a producer.