(init-and-start-task-pool make-task pool-id concurrency-level)
(make-task logger exception-handler process-record poll-interval make-kafka-consumer task-id)
(stop-task-pool {:keys [native-pool tasks]} shutdown-timeout)
(write writer topic key val)
(write-async writer topic key val)