(close consumer)
(create-async-commit-consumer kafka-configs msg-handler & opts)
(create-auto-commit-consumer kafka-configs msg-handler & opts)
(create-partial-async-commit-consumer kafka-configs msg-handler & opts)
(create-partial-sync-commit-consumer kafka-configs msg-handler & opts)
(create-sync-commit-consumer kafka-configs msg-handler & opts)
(retriable-message-handler handler max-retry-times)
(safety-net-message-handler handler)
(safety-net-message-handler handler error-consumer)
(subscribe consumer topic)
(to-message-handler handler-fn)
(to-value-only-message-handler handler-fn)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close