(process-batch batch stop {:keys [job-name func send-report]})
(record->message record)
(run-loop consumer stop {:keys [job-name func send-report] :as config})
(start-job {:keys [kafka monitor-name job-name topics] :as config})
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close