felice.async — com.oscaro/felice 3.2.0-1.6

async-enabled? clj

close! clj

(close! {:keys [close!] :as consumer})

commit-message-offset clj

(commit-message-offset consumer message)

consumer clj

(consumer conf key-deserializer value-deserializer topic->chan)

(consumer conf key-deserializer value-deserializer records-chan & topics)

poll-chan clj

(poll-chan consumer poll-timeout records-chan control-chan)

poll-chans clj

(poll-chans consumer poll-timeout topic->chan control-chan)