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

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-message-handler clj

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

safety-net-message-handler clj

(safety-net-message-handler handler)

(safety-net-message-handler handler error-consumer)

subscribe clj

(subscribe consumer topic)

to-message-handler clj

(to-message-handler handler-fn)

to-value-only-message-handler clj

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