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

collectclj

(collect streams-builder)

Collects the test results. The test driver returns a list of messages with each message formatted like "key:value"

Collects the test results. The test driver returns a list of messages with
each message formatted like "key:value"
sourceraw docstring

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]})
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
sendclj
(send topology topic-config key message)
Publishes message to a topic.


Publishes message to a topic.

sourceraw docstring
streams-builderclj
(streams-builder)
(streams-builder streams-builder)
Creates a mock streams-builder.


Creates a mock streams-builder.

sourceraw docstring
streams-builder->test-driverclj
(streams-builder->test-driver streams-builder)
sourceraw docstring
topicclj
(topic topic-name)
Helper to create a topic.


Helper to create a topic.

sourceraw docstring
cljdoc is a website building & hosting documentation for Clojure/Script libraries
Keyboard shortcutsReport a problemcljdoc on GitHub
× close