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

all-topics clj

(all-topics zk-utils)

Returns a lazy sequence of all Kafka topics visible in the current connection.

create-topic! clj

(create-topic! zk-utils topic partitions)

(create-topic! zk-utils topic partitions replication-factor)

(create-topic! zk-utils topic partitions replication-factor topic-config)

(create-topic! zk-utils
               topic
               partitions
               replication-factor
               topic-config
               rack-aware-mode)

Creates a topic with a given name, number of partitions, replication factor, and optional topic configuration.

Topic configuration should be specified by a Clojure map, example: {"cleanup.policy" "compact"}, which will be converted to Java Properties, or alternatively via Java Properties directly.

If no replication factor is provided, a replication factor of 1 is assumed.

If the topic already exists in Zookeeper, a TopicExistsException will be thrown, If the topic otherwise collides with an existing topic, an InvalidTopicException will be thrown.

Note: It may take some time for a topic and its partitions to propogate and the client isn't notified and doesn't block waiting for this automatically. Be careful if auditing the topic and its partitions before this happens. Inconsistent ZK state may interfere with queries that pull from related Zookeeper nodes. Typically You will receive a NoNodeException in these cases. If your application requires constant polling of admin state, either try to block until the operation completes and/or check the associated Zookeeper nodes manually using a Zookeeper client.

delete-topic! clj

(delete-topic! zk-utils topic)

Marks a topic for deletion. After a topic has been marked for deletion, it will no longer accept requests to produce or consume.

Note that this does not mean the topic will be deleted immediately. If for example you check if the topic exists, it may still return true.

If the topic has already been marked for deletion in Zookeeper, a TopicAlreadyMarkedForDeletionException will be thrown. If another error occurs, an AdminOperationException will be thrown.

delete-topic-path clj

(delete-topic-path topic)

delete-topics-path clj

(delete-topics-path)

topic-exists? clj

(topic-exists? zk-utils topic)

topic-path clj

(topic-path topic)

topic-replica-assignments clj

(topic-replica-assignments zk-utils topics)

Returns the assigned replicas for a given list of topics.

Returns a vector of maps where the key is the topic partition and the values are a vector of assigned replica IDs.

Example:

{{:topic "cheeses", :partition 0} [1001], {:topic "gigantic-cheeses", :partition 0} [1001]}

topics-by-consumer-group clj

(topics-by-consumer-group zk-utils group)

Returns all the topics for a particular consumer group name.

topics-metadata clj

(topics-metadata zk-utils topics)