clj-kafka.admin documentation

clj-kafka.admin

Administration operations.

(change-topic-config zk topic config)

(create-topic zk topic)

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

(delete-topic zk topic)

(topic-config zk topic)

(topic-exists? zk topic)

(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.