Liking cljdoc? Tell your friends :D
Clojure only.

fr33m0nk.alpakka-kafka.committer

committer-settingsclj

(committer-settings
  actor-system
  &
  {:keys [batch-size max-interval-in-ms parallelism wait-for-commit-ack
          commit-when-offset-first-observed]
   :or {wait-for-commit-ack true commit-when-offset-first-observed true}
   :as _options})
source

flowclj

(flow committer-settings)
source

flow-with-offset-contextclj

(flow-with-offset-context committer-settings)
source

sinkclj

(sink committer-settings)
source

sink-with-offset-contextclj

(sink-with-offset-context committer-settings)
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