(integration-fixture build-fn
{:keys [broker-config topic-metadata app-config enable?]})
(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
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
(skip-to-end {:keys [topic config]})
Returns a fixture that skips to the end of the supplied topic before running the test function
Returns a fixture that skips to the end of the supplied topic before running the test function
(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.
Returns a fixture function that creates all the topics named in the supplied topic config before running a test function.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close