jackdaw.streams.mock — fundingcircle/jackdaw 0.7.3

Mocks for testing kafka streams.

build-driver clj

(build-driver f)

collect clj

(collect streams-builder)

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

consume clj

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

get-keyvals clj

(get-keyvals test-driver topic-config)

get-records clj

(get-records test-driver topic-config)

producer clj

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

publish clj

(publish test-driver topic-config k v)

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

repeatedly-consume clj

(repeatedly-consume test-driver topic-config)

send clj

(send topology topic-config key message)

Publishes message to a topic.

streams-builder clj

(streams-builder)

(streams-builder streams-builder)

Creates a mock streams-builder.

streams-builder->test-driver clj

(streams-builder->test-driver streams-builder)

topic clj

(topic topic-name)

Helper to create a topic.