kafka-clojure-client.consumer — cn.leancloud/kafka-clojure-client 0.0.6

catch-all-exception-record-handler clj

(catch-all-exception-record-handler handler)

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

close clj

(close consumer)

create-async-commit-consumer clj

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

create-auto-commit-consumer clj

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

create-partial-async-commit-consumer clj

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

create-partial-sync-commit-consumer clj

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

create-sync-commit-consumer clj

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

retriable-record-handler clj

(retriable-record-handler handler max-retry-times)

subscribe clj

(subscribe consumer topics)

to-record-handler clj

(to-record-handler handler-fn)

to-value-only-record-handler clj

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