Liking cljdoc? Tell your friends :D
Clojure only.

org.purefn.river.batch

A consumer suitable for batch reading operations from Kafka.

A consumer suitable for batch reading operations from Kafka.
raw docstring

batch-consumerclj

(batch-consumer config process-fn)
source

create-consumersclj

(create-consumers {:keys [:org.purefn.river.batch/topics
                          :org.purefn.river.batch/group-id
                          :org.purefn.river.batch/threads
                          :org.purefn.river.batch/bootstrap-servers]
                   :as config})
source

default-configclj

(default-config)
(default-config config)

The default configuration for a batch consumer.

  • ::topics The topics to consumer from.

  • ::bootstrap-servers hostname:port of a broker in the Kafka cluster to sink from.

  • ::threads The number of threads (consumers) to create for each topic. (default 4)

  • ::group-id The group-id of the conumser group, used when committing offsets.

The default configuration for a batch consumer.

- `::topics` The topics to consumer from.

- `::bootstrap-servers` hostname:port of a broker in the Kafka cluster to sink from.

- `::threads` The number of threads (consumers) to create for each topic. 
(default 4)

- `::group-id` The group-id of the conumser group, used when committing offsets.
sourceraw docstring

kafka-consumerclj

(kafka-consumer group-id servers)
source

max-arg-countclj

(max-arg-count f)
source

processclj

(process consumer
         closing
         {:keys [:org.purefn.river.batch/timeout] :as config}
         dependencies
         process-fn)
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

Keyboard shortcutsReport a problemcljdoc on GitHub
× close