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

admin-url clj

(admin-url kafka-connect-server)

bootstrap-servers-key clj

hostname clj

(hostname kafka-connect-server)

json-converter-classname clj

kafka-connect-server clj

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

key-converter-key clj

offset-storage-file clj

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

offset-storage-file-filename-key clj

port clj

(port kafka-connect-server)

rest-host-name-key clj

rest-port-key clj

start clj

(start kafka-connect-server)

stop clj

(stop kafka-connect-server)

value-converter-key clj

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)