kafka.testing.broker — io.logicblocks/kafka.testing 0.0.1

bootstrap-servers clj

(bootstrap-servers kafka-broker)

hostname clj

(hostname kafka-broker)

kafka-broker clj

(kafka-broker & {:as options})

log-directory clj

(log-directory kafka-broker)

port clj

(port kafka-broker)

start clj

(start kafka-broker)

stop clj

(stop kafka-broker)

with-fresh-kafka-broker clj

(with-fresh-kafka-broker kafka-broker-atom zookeeper-atom & options)

with-running-kafka-broker clj

(with-running-kafka-broker kafka-broker-atom)