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

bootstrap-servers clj

(bootstrap-servers broker)

hostname clj

(hostname broker)

kafka-broker clj

(kafka-broker & {:as options})

log-directory clj

(log-directory broker)

port clj

(port broker)

start clj

(start broker)

stop clj

(stop broker)

with-fresh-kafka-broker clj

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

with-running-kafka-broker clj

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