kafka-utils.core — kafka-utils 0.1.1

->chan clj

(->chan consumer)

(->chan consumer poll-timeout)

apply-transducer clj

(apply-transducer xf in-chan)

latest-only clj

(latest-only db id-attr)

latest-update-before clj

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

read-from-beginning clj

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

read-from-end clj

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

sink-to-db! clj

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