franzy.admin.configuration
all-client-configsclj
(all-client-configs zk-utils)Returns all client configurations from Zookeeper
Returns all client configurations from Zookeeper
all-configsclj
(all-configs zk-utils)(all-configs zk-utils include-defaults?)Returns all configs in the cluster.
Note: This is a convenience method, that makes multiple queries.
Returns all configs in the cluster. > Note: This is a convenience method, that makes multiple queries.
all-entities-with-configsclj
(all-entities-with-configs zk-utils config-type)Returns all entity names that have a configuration.
Example:
(all-entities-with-configs zk-utils :topics)
Returns all entity names that have a configuration. Example: `(all-entities-with-configs zk-utils :topics)`
all-entity-configsclj
(all-entity-configs zk-utils config-type)(all-entity-configs zk-utils config-type include-defaults?)Returns all topic or client configurations from Zookeeper, as specified by the config-type.
See (all-topics-configuration) for an example.
Returns all topic or client configurations from Zookeeper, as specified by the config-type. See (all-topics-configuration) for an example.
all-topic-configsclj
(all-topic-configs zk-utils)Returns all topic configurations from Zookeeper.
Returns a maps with topic names as keys and configuration maps as values. If you did not specify a configuration on topic creation or otherwise modify it later, an empty map is returned for the topic configuration. Note this does not mean there is no configuration, but rather the topic will be using Kafka defaults.
Example:
{:all-my-friends {:cleanup.policy "compact"} :people-who-died {}}
Returns all topic configurations from Zookeeper.
Returns a maps with topic names as keys and configuration maps as values.
If you did not specify a configuration on topic creation or otherwise modify it later,
an empty map is returned for the topic configuration.
Note this does not mean there is no configuration, but rather the topic will be using Kafka defaults.
Example:
`{:all-my-friends {:cleanup.policy "compact"} :people-who-died {}}`config-change-znode-dataclj
(config-change-znode-data config-type entity-name)Gets znode data for configuration nodes in Zookeeper.
Gets znode data for configuration nodes in Zookeeper.
default-config-xfclj
Transducer to remove defaukt configurations.
Transducer to remove defaukt configurations.
entity-configclj
(entity-config zk-utils config-type entity)Returns the entity (topic or client) config (if any) from Zookeeper, given a config type and an entity.
Returns the entity (topic or client) config (if any) from Zookeeper, given a config type and an entity.
entity-config-changes-pathclj
(entity-config-changes-path)entity-config-pathclj
(entity-config-path config-type entity)entity-config-root-pathclj
(entity-config-root-path config-type)update-client-config!clj
(update-client-config! zk-utils client-id config)update-topic-config!clj
(update-topic-config! zk-utils topic config)Updates an existing topic's configuration, given a topic configuration map.
Example:
(update-topic-config! "sandwiches-of-unusual-size" {:cleanup-policy compact})
Note: Config changes needs to replicate to other brokers, therefore changes may not be instantaneous. Do not implement behaviors that depend on this change being instant, minimally check if the target broker has received the change. A change notification will be created internally to propogate the configuration change to other brokers.
Updates an existing topic's configuration, given a topic configuration map.
Example:
`(update-topic-config! "sandwiches-of-unusual-size" {:cleanup-policy compact})`
> Note: Config changes needs to replicate to other brokers, therefore changes may not be instantaneous.
Do not implement behaviors that depend on this change being instant, minimally check if the target broker has
received the change.
A change notification will be created internally to propogate the configuration change to other brokers.cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close