(catch-all-exception-record-handler handler)
(catch-all-exception-record-handler handler error-consumer)
(create-async-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)
(retriable-record-handler handler max-retry-times)
(retriable-record-handler handler max-retry-times retry-interval-ms)
(subscribe-to-pattern consumer pattern)
(subscribe-to-pattern consumer pattern on-unsubscribe-callback)
(subscribe-to-topics consumer topics)
(subscribe-to-topics consumer topics on-unsubscribe-callback)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close