(catch-all-exception-record-handler handler)
(catch-all-exception-record-handler handler error-consumer)
(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-record-handler handler max-retry-times)
(subscribe consumer topics)
(to-record-handler handler-fn)
(to-value-only-record-handler handler-fn)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close