Liking cljdoc? Tell your friends :D

rp.jackdaw.processor

Lightweight component wrapper around jackdaw Streams (DSL) processor app.

Lightweight component wrapper around jackdaw Streams (DSL) processor app.
raw docstring

rp.jackdaw.producer

Lightweight component wrapper around jackdaw producer client.

Lightweight component wrapper around jackdaw producer client.
raw docstring

rp.jackdaw.state-store

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).
raw docstring

rp.jackdaw.subscriber

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].
raw docstring

rp.jackdaw.topic-registry

No vars found in this namespace.

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close