fr33m0nk.alpakka-kafka.committer — net.clojars.fr33m0nk/clj-alpakka-kafka 0.1.3

committer-settings clj

(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})

flow clj

(flow committer-settings)

flow-with-offset-context clj

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

sink clj

(sink committer-settings)

sink-with-offset-context clj

(sink-with-offset-context committer-settings)