franzy.admin.cluster
all-brokers
(all-brokers zk-utils)Returns a list of all the broker info for each broker in the cluster.
assign-replicas-to-brokers
(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-endpoints-for-channel
(broker-endpoints-for-channel zk-utils protocol-type)Returns all broker info in the cluster matching a keyword representing the given protocol type.
Valid values are: :ssl :plaintext :sasl_plaintext :sasl_ssl :trace
broker-ids
(broker-ids zk-utils)Gets a sorted list of broker IDs.
broker-ids-path
(broker-ids-path)broker-metadata
(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
(broker-sequence-id-path)broker-topics-path
(broker-topics-path)delete-broker-topic-path!
(delete-broker-topic-path! zk-utils broker-id topic)Deletes the broker topic path in Zookeeper.
manual-replication-assignment
(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.