kafka.testing.connect — io.logicblocks/kafka.testing 0.0.2

admin-url clj

(admin-url kafka-connect-server)

configuration clj

(configuration kafka-connect-server)

defaulted-options clj

(defaulted-options options)

json-converter-classname clj

kafka-connect-server clj

(kafka-connect-server & {:as options})

offset-storage-file-filename clj

(offset-storage-file-filename kafka-connect-server)

rest-host-name clj

(rest-host-name kafka-connect-server)

rest-port clj

(rest-port kafka-connect-server)

start clj

(start kafka-connect-server)

stop clj

(stop kafka-connect-server)

with-fresh-kafka-connect-server clj

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

with-running-kafka-connect-server clj

(with-running-kafka-connect-server kafka-connect-server-atom)