clj-kafka.zk — clj-kafka 0.3.4

broker-list clj

(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"}))

brokers clj

(brokers m)

Get brokers from zookeeper

committed-offset clj

(committed-offset m consumer-group topic partition)

controller clj

(controller m)

Get leader node

offset-path clj

(offset-path consumer-group topic partition)

partitions clj

(partitions m topic)

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

set-offset! clj

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

topics clj

(topics m)

Get topics