Liking cljdoc? Tell your friends :D

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 is a website building & hosting documentation for Clojure/Script libraries

× close