dvlopt.kstreams.mock
Building a mock Kafka Streams application which do not need a Kafka cluster.
Building a mock Kafka Streams application which do not need a Kafka cluster.
advanceclj
(advance mock-app interval)Advances the wall-clock time of the mock application.
Advances the wall-clock time of the mock application.
disbandclj
(disband mock-app)Closes the mock application and releases all associated resources.
Closes the mock application and releases all associated resources.
kv-storeclj
(kv-store mock-app store-name)Retrieves a writable key-value store used by the mock application.
Retrieves a writable key-value store used by the mock application.
metricsclj
(metrics mock-app)Cf. dvlopt.kstreams/metrics
Cf. `dvlopt.kstreams/metrics`
mock-appclj
(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.
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-recordclj
(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
Processes the given records by the mock application. Cf. `dvlopt.kafka.in/poll` for the structure of a record ready to be consumed
read-recordclj
(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
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-storeclj
(session-store mock-app store-name)Retrieves a writable session store used by the application.
Retrieves a writable session store used by the application.
window-storeclj
(window-store mock-app store-name)Retrieves a read-only window store used by the application.
Retrieves a read-only window store used by the application.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close