Lightweight component wrapper around jackdaw Streams (DSL) processor app.
Lightweight component wrapper around jackdaw Streams (DSL) processor app.
(cleanup! component)Delete the local state store directory. Will throw an exception when the Streams app is currently running, so best to call this before starting or after stopping.
Delete the local state store directory. Will throw an exception when the Streams app is currently running, so best to call this before starting or after stopping.
(mock-get-keyvals mock-processor topic-kw)Get KV pairs from a specific output topic of a mock processor.
Get KV pairs from a specific output topic of a mock processor.
(mock-produce! mock-processor topic-kw k v)(mock-produce! mock-processor topic-kw time-ms k v)Produce a KV to a specific topic of a mock processor (with optional timestamp).
Produce a KV to a specific topic of a mock processor (with optional timestamp).
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |