manifold-kafka.producer — manifold-kafka 0.0.1

producer clj

(producer producer-config topic)

takes a kafka producer config map and a topic and returns a manifold stream representing the kafka topic producer-config properties are those of kafka.producer.ProducerConfig Put a message on the stream to put it on the Kafka topic If a message has both :key and :val then the message will be put onto kafka using that key and val, otherwise the whole message will be used. Closing the stream will close the Kafka Producer.