kafka.testing.broker — io.logicblocks/kafka.testing 0.0.3-RC6

bootstrap-servers clj

(bootstrap-servers kafka-broker)

configuration clj

(configuration kafka-broker)

defaulted-options clj

(defaulted-options options)

host-name clj

(host-name kafka-broker)

kafka-broker clj

(kafka-broker & {:as options})

log-dir clj

(log-dir kafka-broker)

offsets-topic-replication-factor clj

(offsets-topic-replication-factor kafka-broker)

port clj

(port kafka-broker)

start clj

(start kafka-broker)

stop clj

(stop kafka-broker)

transaction-topic-replication-factor clj

(transaction-topic-replication-factor 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)