cddr.kafka.test.fixtures — cddr/test-machine 1.0.2-4-gc789324

default-reset-fn clj

(default-reset-fn rt args)

delete-recursively clj

(delete-recursively fname)

empty-state-fixture clj

(empty-state-fixture app-config)

integration-fixture clj

(integration-fixture build-fn
                     {:keys [broker-config topic-metadata app-config enable?]})

kstream-fixture clj

(kstream-fixture {:keys [topology config]})

Returns a fixture that builds and starts kafka streams for the supplied topology before running the test function (and then tears it down when the test is complete).

compose-fixtures or join-fixtures may be used to build fixtures combine topologies

list-topics clj

(list-topics client)

reset-application-fixture clj

(reset-application-fixture app-config)

(reset-application-fixture app-config reset-args)

(reset-application-fixture app-config reset-args reset-fn)

Returns a fixture that runs the kafka.tools.StreamsResetter with the supplied reset-args as parameters

service-ready? clj

(service-ready? {:keys [http-url http-params timeout]})

skip-to-end clj

(skip-to-end {:keys [topic config]})

Returns a fixture that skips to the end of the supplied topic before running the test function

topic-fixture clj

(topic-fixture kafka-config topic-config)

(topic-fixture kafka-config topic-config timeout-ms)

Returns a fixture function that creates all the topics named in the supplied topic config before running a test function.

with-fixtures clj macro

(with-fixtures fixtures & body)