franzy.admin.cluster — clj-kafka.franzy/admin 2.0.7

all-brokers clj

(all-brokers zk-utils)

Returns a list of all the broker info for each broker in the cluster.

assign-replicas-to-brokers clj

(assign-replicas-to-brokers broker-ids partitions replication-factor)

(assign-replicas-to-brokers broker-ids
                            partitions
                            replication-factor
                            fixed-start-index
                            start-partition-id)

broker-ids clj

(broker-ids zk-utils)

Gets a sorted list of broker IDs.

broker-ids-path clj

(broker-ids-path)

broker-metadata clj

(broker-metadata zk-utils broker-id)

Returns broker info from Zookeeper, given a broker id.

If the broker dies before the Zookeeper query finishes, an exception will be thrown.

broker-sequence-id-path clj

(broker-sequence-id-path)

broker-topics-path clj

(broker-topics-path)

delete-broker-topic-path! clj

(delete-broker-topic-path! zk-utils broker-id topic)

Deletes the broker topic path in Zookeeper.

manual-replication-assignment clj

(manual-replication-assignment replica-assignments
                               broker-ids
                               start-partition-id)

(manual-replication-assignment replica-assignments
                               broker-ids
                               start-partition-id
                               check-broker-available?)

Creates a manual replication assignment map, given a string of replica assignments, a set of broker ids, a start partition id, and an optional check if a broker is available.