Liking cljdoc? Tell your friends :D
Clojure only.

ziggurat.kafka-consumer.consumer-handler

batch-consumption-metric-nsclj

source

commit-metric-nsclj

source

commit-offsetsclj

(commit-offsets consumer topic-entity)

Synchronously commits the current consumer offsets. Invoked only when a batch route is configured with :manual-commit-enabled, so offsets are committed after a batch has been processed (handler executed and any failures enqueued to the retry queue) rather than by Kafka's background auto-commit.

A commit failure is logged and reported as a metric but does NOT halt the poll loop; the offsets will be committed on the next successful commit, preserving at-least-once delivery.

Synchronously commits the current consumer offsets. Invoked only when a batch route is
configured with `:manual-commit-enabled`, so offsets are committed after a batch has been
processed (handler executed and any failures enqueued to the retry queue) rather than by
Kafka's background auto-commit.

A commit failure is logged and reported as a metric but does NOT halt the poll loop; the
offsets will be committed on the next successful commit, preserving at-least-once delivery.
sourceraw docstring

DEFAULT_POLL_TIMEOUT_MS_CONFIGclj

source

poll-for-messagesclj

(poll-for-messages consumer handler-fn topic-entity consumer-config)
source

processclj

(process batch-handler batch-payload)
source

validate-batch-processing-resultclj

(validate-batch-processing-result result)
source

validate-return-typeclj

(validate-return-type result)
source

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
←Move to previous article
→Move to next article
Ctrl+/Jump to the search field
Raise an issueBrowse cljdoc sourceChat on Slack
× close