ottla.consumer — com.joshuadavey/ottla 0.1.0

default-exception-handler clj

(default-exception-handler e)

IShutdown clj protocol

graceful-shutdown clj

(graceful-shutdown _)

shutdown-await clj

(shutdown-await _ await-time-ms)

status clj

(status _)

start-consumer clj

(start-consumer {:keys [conn-map] :as config}
                {:keys [topic] :as basic-selection}
                handler
                {:keys [poll-ms deserialize-key deserialize-value xform
                        exception-handler await-close-ms listen-ms]
                 :or {poll-ms 15000
                      await-close-ms 1000
                      listen-ms 2
                      exception-handler default-exception-handler
                      xform identity}
                 :as opts})

with-commit-mode clj macro

(with-commit-mode [conn commit-mode] & body)