Lightweight component wrapper around jackdaw Streams (DSL) processor app.
Lightweight component wrapper around jackdaw Streams (DSL) processor app.
Lightweight component wrapper around jackdaw producer client.
Lightweight component wrapper around jackdaw producer client.
Adds a protocol-based wrapper for interacting with KV state stores.
Includes some store-related utilities as well.
Nothing really jackdaw-specific here, but including in this library anyway.
Useful when dealing with explicit state stores using the lower-level Processor API
(for example via the Streams transform
method).
Adds a protocol-based wrapper for interacting with KV state stores. Includes some store-related utilities as well. Nothing really jackdaw-specific here, but including in this library anyway. Useful when dealing with explicit state stores using the lower-level Processor API (for example via the Streams `transform` method).
A Processor component that simply consumes from one or more topics and calls a callback for each record.
Like Processor
it takes app-config
and topic-registry
.
Unlike Processor
instead of a topology-builder-fn
it takes:
topic-kws
: a collection of keywords identifying topics to consume.
callback-fn
: a function that's called for each record; it's passed a map with the keys [:k :v :component].
A Processor component that simply consumes from one or more topics and calls a callback for each record. Like `Processor` it takes `app-config` and `topic-registry`. Unlike `Processor` instead of a `topology-builder-fn` it takes: `topic-kws`: a collection of keywords identifying topics to consume. `callback-fn`: a function that's called for each record; it's passed a map with the keys [:k :v :component].
No vars found in this namespace.
Some handy functions for use in the repl.
Some handy functions for use in the repl.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close