Liking cljdoc? Tell your friends :D
Clojure only.

jackdaw.streams.mock

Mocks for testing kafka streams.

Mocks for testing kafka streams.
raw docstring

build-driverclj

(build-driver f)
source

build-topology-driverclj

(build-topology-driver f)
source

consumeclj

(consume test-driver {:keys [topic-name key-serde value-serde]})
source

get-keyvalsclj

(get-keyvals test-driver topic-config)
source

get-recordsclj

(get-records test-driver topic-config)
source

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
sourceraw docstring

publishclj

(publish test-driver topic-config k v)
(publish test-driver topic-config time-ms k v)
source

repeatedly-consumeclj

(repeatedly-consume test-driver topic-config)
source

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
sourceraw docstring

topicclj

(topic topic-name)

Helper to create a topic.

Helper to create a topic.
sourceraw docstring

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
sourceraw docstring

cljdoc builds & hosts documentation for Clojure/Script libraries

Keyboard shortcuts
Ctrl+kJump to recent docs
←Move to previous article
→Move to next article
Ctrl+/Jump to the search field
Raise an issueBrowse cljdoc sourceChat on Slack
× close