crank.job — ua.kasta/crank 1.2.1

messages->offsets clj

(messages->offsets messages)

record->message clj

(record->message record)

run-loop clj

(run-loop consumer
          stop
          {:keys [job-name func send-report topics attempts]
           :or {attempts 0}
           :as config})

start-job clj

(start-job {:keys [kafka monitor-name job-name] :as config})