kafka-utils.core

Liking cljdoc? Tell your friends :D

Clojure only.

(->chan consumer)

(->chan consumer poll-interval)

(latest-only db id-attr)

(latest-update-before db timestamp id id-attr updated-at-attr)

(read-from-beginning topic-name
                     bootstrap-servers
                     key-deserializer
                     value-deserializer)

(read-from-end topic-name bootstrap-servers key-deserializer value-deserializer)

(sink-to-db! chan db-conn)

cljdoc is a website building & hosting documentation for Clojure/Script libraries