Liking cljdoc? Tell your friends :D
Clojure only.

kafka-clojure-client.consumer

catch-all-exception-record-handlerclj

(catch-all-exception-record-handler handler)
(catch-all-exception-record-handler handler error-consumer)
source

closeclj

(close consumer)
source

create-async-commit-consumerclj

(create-async-commit-consumer kafka-configs msg-handler & opts)
source

create-auto-commit-consumerclj

(create-auto-commit-consumer kafka-configs msg-handler & opts)
source

create-partial-async-commit-consumerclj

(create-partial-async-commit-consumer kafka-configs msg-handler & opts)
source

create-partial-sync-commit-consumerclj

(create-partial-sync-commit-consumer kafka-configs msg-handler & opts)
source

create-sync-commit-consumerclj

(create-sync-commit-consumer kafka-configs msg-handler & opts)
source

retriable-record-handlerclj

(retriable-record-handler handler max-retry-times)
(retriable-record-handler handler max-retry-times retry-interval-ms)
source

subscribe-to-patternclj

(subscribe-to-pattern consumer pattern)
source

subscribe-to-topicsclj

(subscribe-to-topics consumer topics)
source

to-record-handlerclj

(to-record-handler handler-fn)
source

to-value-only-record-handlerclj

(to-value-only-record-handler handler-fn)
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

Keyboard shortcutsReport a problemcljdoc on GitHub
× close