dvlopt.kstreams.mock — dvlopt/kafka 1.2.0-beta1

Building a mock Kafka Streams application which do not need a Kafka cluster.

advance clj

(advance mock-app interval)

Advances the wall-clock time of the mock application.

disband clj

(disband mock-app)

Closes the mock application and releases all associated resources.

kv-store clj

(kv-store mock-app store-name)

Retrieves a writable key-value store used by the mock application.

metrics clj

(metrics mock-app)

Cf. dvlopt.kstreams/metrics

mock-app clj

(mock-app application-id topology)

(mock-app application-id topology options)

Given a topology, creates a mock Kafka Streams application which can simulate a cluster. It is very useful for testing and fiddling at the REPL.

It is mainly operated by using pipe-record and read-record.

A map of options may be given :

::wall-clock (defaults to 0) Timestamp for initiating the mock application. Cf. dvlopt.kstreams.ctx/schedule for a description of the difference between :wall-clock-time and :stream-time

:dvlopt.kstreams/configuration Cf. dvlopt.kstreams/app, many properties are ignored but it is useful to supply something realistic.

pipe-record clj

(pipe-record mock-app record)

Processes the given records by the mock application.

Cf. dvlopt.kafka.in/poll for the structure of a record ready to be consumed (headers not supported)

read-record clj

(read-record mock-app topic)

(read-record mock-app topic options)

Records processed after using pipe-record may produce an output depending on the topology of the mock application.

Cf. dvlopt.kafka.out/send for the structure of a record produced by the mock application

session-store clj

(session-store mock-app store-name)

Retrieves a writable session store used by the application.

window-store clj

(window-store mock-app store-name)

Retrieves a read-only window store used by the application.