kafka-clj.consumer.util — kafka-clj 4.0.3

get-broker-offsets clj

(get-broker-offsets {:keys [metadata-connector]} metadata topics conf)

metadata {"abc" [{:host "localhost", :port 50738, :isr [{:host "localhost", :port 50738}], :id 0, :error-code 0}]}

get-offsets clj

(get-offsets metadata-connector host-address topic partitions)

transform-offsets clj

(transform-offsets topic
                   offsets-response
                   {:keys [use-earliest] :or {use-earliest true}})