kafka-component.core — kafka-component 0.6.3

init-and-start-task-pool clj

(init-and-start-task-pool make-task pool-id concurrency-level)

make-consumer clj multimethod

make-producer clj multimethod

make-task clj

(make-task logger
           exception-handler
           process-record
           poll-interval
           make-kafka-consumer
           task-id)

panic! clj

(panic!)

stop-task-pool clj

(stop-task-pool {:keys [native-pool tasks]} shutdown-timeout)

try-or-panic clj/s macro

(try-or-panic task-id panic-msg & body)

with-err-str clj/s macro

(with-err-str & body)

write clj

(write writer topic key val)

write-async clj

(write-async writer topic key val)