clj-kafka.admin — clj-kafka 0.3.4

Administration operations.

change-topic-config clj

(change-topic-config zk topic config)

create-topic clj

(create-topic zk topic)

(create-topic zk
              topic
              {:keys [partitions replication-factor config]
               :or {partitions 1 replication-factor 1 config nil}})

delete-topic clj

(delete-topic zk topic)

topic-config clj

(topic-config zk topic)

topic-exists? clj

(topic-exists? zk topic)

zk-client clj

(zk-client servers)

(zk-client servers
           {:keys [session-timeout-ms connection-timeout-ms]
            :as opts
            :or {session-timeout-ms 10000 connection-timeout-ms 10000}})

Create a ZkClient for use with the functions in this namespace. Servers is a Zookeeper connection string.