jackdaw.streams.mock — fundingcircle/jackdaw 0.9.12

Mocks for testing kafka streams.

build-driver clj

(build-driver f)

build-topology-driver clj

(build-topology-driver f)

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]})

Returns a function which can be used to publish data to a topic for the topology test driver

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)

streams-builder->test-driver clj

(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

topic clj

(topic topic-name)

Helper to create a topic.

topology->test-driver clj

(topology->test-driver topology)

Given a kafka streams topology, return a topology test driver for it