shovel.producer — shovel 0.3.1

kafka-producer clj

(kafka-producer h)

Takes a hashmap for configuration and returns a KafkaProducer that can be used to send messages

producer-close clj

(producer-close producer)

Takes a producer and calls .close() on it

producer-record clj

(producer-record topic payload)

Takes a topic and a payload and created a ProducerRecord that is returned

producer-send-async clj

(producer-send-async producer record)

Takes a record and sends it, returns immediately

producer-send-sync clj

(producer-send-sync producer record timeout)

Takes a record and sends it, returns after the send or the timeout