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

Lightweight component wrapper around jackdaw producer client.

Implements an EDN SerDe (Serializer/Deserializer). While the native jackdaw EDN SerDe fulfills
most purposes, in order for the RentPath Kafka Connect EdnConverter
(https://search.maven.org/artifact/com.rentpath/kafka-connect-converters/0.1.1/jar) to infer
the requisite schema from the data itself, said data must conform to a series of further rules
above and beyond those normally associated with the EDN specification; namely, that all compound
data structures be consistent, their elements homogeneous in both type and structure. This SerDe
exists to provide an (optional) means of validating these additional requirements, so as to ensure
that no data from which a schema may not be autoderived (and thus unable to be sunk) is produced
to any Kafka topic that is intended for Kafka Connect sinking.

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

Some handy functions for use in the repl.