clj-kafka.producer

message

(message topic value)(message topic key value)

producer

(producer m)

Creates a Producer. m is the configuration metadata.broker.list : “server:port,server:port”

send-message

(send-message producer message)

send-messages

(send-messages producer messages)