jackdaw.streams.mock — net.clojars.savya/jackdaw 1.3.3

Mocks for testing kafka streams.

build-driver clj

(build-driver f)

Builds a TopologyTestDriver by applying f to a fresh streams-builder and compiling the resulting topology.

build-topology-driver clj

(build-topology-driver f)

Builds a TopologyTestDriver by applying f to a fresh low-level Topology.

consume clj

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

Reads and datafies the next available record from topic-config's output topic on the mock test-driver, or returns nil if none is ready.

get-keyvals clj

(get-keyvals test-driver topic-config)

Drains topic-config on the mock test-driver, returning a sequence of [key value] pairs.

get-records clj

(get-records test-driver topic-config)

Drains topic-config on the mock test-driver, returning a sequence of full datafied records (the same as repeatedly-consume).

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)

Pipes a single record with key k and value v (optionally at time-ms) into topic-config's topic on the mock test-driver.

repeatedly-consume clj

(repeatedly-consume test-driver topic-config)

Lazily consumes from topic-config on the mock test-driver until the output topic is drained, returning a sequence of datafied records.

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