(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)
(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)
(consume-records-offset {:keys [decode-value-as-json] :as consumer-settings}
topic
channel
partition
offset)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close