clj-kafka.zk

broker-list

(broker-list brokers)

Returns a comma separated list of Kafka brokers, as returned from clj-kafka.zk/brokers. e.g.: (broker-list (brokers {“zookeeper.connect” “127.0.0.1:2181”}))

view source

brokers

(brokers m)

Get brokers from zookeeper

view source

committed-offset

(committed-offset m consumer-group topic partition)
view source

controller

(controller m)

Get leader node

view source

offset-path

(offset-path consumer-group topic partition)
view source

partitions

(partitions m topic)

Returns a map of partitions and replica ids. e.g. {“1” [0], “0” [0]}

view source

set-offset!

(set-offset! m consumer-group topic partition offset)
view source

topics

(topics m)

Get topics

view source