Liking cljdoc? Tell your friends :D
Clojure only.

kafka-util.core

compute-default-partitionclj

(compute-default-partition key-bytes partitions)
source

consume-records-latestclj

(consume-records-latest {:keys [decode-value-as-json] :as consumer-settings}
                        topic
                        channel)
(consume-records-latest {:keys [decode-value-as-json] :as consumer-settings}
                        topic
                        channel
                        partition)

consumer-settings is a map {:key-deserializer :string/:long, :security-protocol : SSL/PLAINTEXT/SASL_PLAINTEXT/SASL_SSL, :broker <string>, :port <int>, :decode-value-as-json true/false

consumer-settings is a map
{:key-deserializer :string/:long,
 :security-protocol : SSL/PLAINTEXT/SASL_PLAINTEXT/SASL_SSL,
 :broker <string>,
 :port <int>,
  :decode-value-as-json true/false
sourceraw docstring

consume-records-minutes-agoclj

(consume-records-minutes-ago {:keys [decode-value-as-json]
                              :as consumer-settings}
                             topic
                             channel
                             minutes-ago)
(consume-records-minutes-ago {:keys [decode-value-as-json]
                              :as consumer-settings}
                             topic
                             channel
                             minutes-ago
                             partition)

consumer-settings is a map {:key-deserializer :string/:long, :security-protocol : SSL/PLAINTEXT/SASL_PLAINTEXT/SASL_SSL, :broker <string>, :port <int>, :decode-value-as-json true/false

consumer-settings is a map
{:key-deserializer :string/:long,
 :security-protocol : SSL/PLAINTEXT/SASL_PLAINTEXT/SASL_SSL,
 :broker <string>,
 :port <int>,
  :decode-value-as-json true/false
sourceraw docstring

consume-records-offsetclj

(consume-records-offset {:keys [decode-value-as-json] :as consumer-settings}
                        topic
                        channel
                        partition
                        offset)

consumer-settings is a map {:key-deserializer :string/:long, :security-protocol : SSL/PLAINTEXT/SASL_PLAINTEXT/SASL_SSL, :broker <string>, :port <int>, :decode-value-as-json true/false}

consumer-settings is a map
{:key-deserializer :string/:long,
 :security-protocol : SSL/PLAINTEXT/SASL_PLAINTEXT/SASL_SSL,
 :broker <string>,
 :port <int>,
 :decode-value-as-json true/false}
sourceraw docstring

with-consumer-group-idcljmacro

(with-consumer-group-id id & body)
source

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

Keyboard shortcutsReport a problemcljdoc on GitHub
× close