clj-kafka-x.admin — net.tbt-post/clj-kafka-x 0.4.0

create-topic clj

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

Creates a topic using provided zk-utils, topic-name and optional key-values. The optional key-values are :partitions --- number of topic partitions (default 1) :replication-factor --- copies (inc original) of each partition (default 1) :topic-config --- Topic specific configuration (default uses broker's default configs) see http://kafka.apache.org/documentation.html#topic-config

e.g

(def z-utils (zk-utils "localhost:2181"))

(create-topic z-utils "topic-a")

(create-topic z-utils "topic-b" :topic-config {"cleanup.policy" "compact"})

delete-topic clj

(delete-topic z-utils topic)

Deletes the given topic

topic-exists? clj

(topic-exists? z-utils topic)

Returns true or false dependant on the existance of the given topic

zk-utils clj

(zk-utils
  zk-url
  &
  {:keys [session-timeout connection-timeout security-enabled]
   :or {session-timeout 1000 connection-timeout 1000 security-enabled false}})