franzy.admin.consumer-groups
consumer-group-active?
(consumer-group-active? zk-utils group)Checks to see if a provided consumer group name is active.
If the group does not exist, throws a Zookeeper ZkNoNodeException internally.
consumer-groups
(consumer-groups zk-utils)Returns all consumer groups in in the scope of the current connection.
consumer-groups-by-topic
(consumer-groups-by-topic zk-utils topic)consumer-partition-owner-path
(consumer-partition-owner-path zk-utils group topic partition)Returns the path in Zookeeper for a consumer group name, topic, and partition.
consumers-groups-per-topic
(consumers-groups-per-topic zk-utils group exclude-internal-topics?)Returns all the consumers for each topic that are part of a given consumer group, optionally excluding internal topics.
consumers-in-group
(consumers-in-group zk-utils group)Returns a list of consumers in a group.
If the group does not exist in Zookeeper, a ZkNoNodeException will be thrown internally, but caught.
consumers-path
(consumers-path)delete-consumer-group!
(delete-consumer-group! zk-utils group)Deletes the whole directory of the given consumer group in Zookeeper if the group is inactive.
Returns true if succeeded.
delete-consumer-groups-for-topic!
(delete-consumer-groups-for-topic! zk-utils topic)(delete-consumer-groups-for-topic! zk-utils topic group)Deletes consumer groups for a topic in Zookeeper if the group is inactive. If the group is provided, only the given group will be deleted, otherwise all groups are deleted.
Throws a NoNodeException if the consumer group does not exist in Zookeeper.