kafka-component.core

init-and-start-task-pool

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

make-consumer

multimethod

make-producer

multimethod

make-task

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

stop-task-pool

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

write

(write writer topic key val)

write-async

(write-async writer topic key val)