trivial-kafka-async.core — org.clojars.lsevero/trivial-kafka-async 0.1.0

consumer! clj

(consumer! {:keys [topic properties duration] :or {duration 100}})

Receives a map of a topic and the japa properties. Returns a channel that will be populated as a message is received in the kafka poll in a different thread.

producer! clj

(producer! {:keys [topic properties flush?] :or {flush? true}})

Receives a map of a topic and the japa properties. Returns a channel that will be consumed and sent each individual message to kafka in a different thread.

worker! clj

(worker! channel f)

Execute a function f each time a message is received at the channel. Checks if a exception is passed in a channel, if it is f will not be applied and the exception will be logged.