crank.kafka — ua.kasta/crank 2.0.0

get-offset clj

(get-offset config topic)

hostname clj

(hostname)

make-consumer clj

(make-consumer config)

make-consumer-config clj

(make-consumer-config config)

normalize-config clj

(normalize-config config)

set-begin! clj

(set-begin! config topic)

set-offset! clj

(set-offset! config topic offset)