 (def default-value-serializer (StringSerializer.))
 
 (defn ^KafkaProducer make-producer
+  "Create a `KafkaProducer` instance by the given `config` map and optional
+  `key-serializer` and `value-serializer` which are responsible for serializing
+  key and value of records. For more information on them please checkout the
+  javadocs for `org.apache.kafka.common.serialization` package."
   ([config]
    (make-producer config default-key-serializer default-value-serializer))
 

;

(defn send
  ([^Producer producer topic v]
   (let [record (ProducerRecord. topic v)]
     (.send producer record)))

     (.send producer record))))

(defn close
  "Close the given `producer` thread pool."
  [^Producer producer]
  (.close producer))
