Liking cljdoc? Tell your friends :D
Clojure only.
jackdaw.streams.mock
Mocks for testing kafka streams.
Mocks for testing kafka streams.
build-driverclj
(build-driver f)build-topology-driverclj
(build-topology-driver f)consumeclj
(consume test-driver {:keys [topic-name key-serde value-serde]})get-keyvalsclj
(get-keyvals test-driver topic-config)get-recordsclj
(get-records test-driver topic-config)producerclj
(producer test-driver {:keys [topic-name key-serde value-serde]})Returns a function which can be used to publish data to a topic for the topology test driver
Returns a function which can be used to publish data to a topic for the topology test driver
publishclj
(publish test-driver topic-config k v)(publish test-driver topic-config time-ms k v)repeatedly-consumeclj
(repeatedly-consume test-driver topic-config)streams-builder->test-driverclj
(streams-builder->test-driver streams-builder)Given the jackdaw streams builder, return a builds the described topology and returns a topology test driver for that topology
Given the jackdaw streams builder, return a builds the described topology and returns a topology test driver for that topology
topology->test-driverclj
(topology->test-driver topology)Given a kafka streams topology, return a topology test driver for it
Given a kafka streams topology, return a topology test driver for it
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close