jackdaw.test.fixtures
kstream-fixture
(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
(list-topics client)
service-ready?
(service-ready? {:keys [http-url http-params timeout]})
skip-to-end
(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
(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
macro
(with-fixtures fixtures & body)