Project

Topics

Namespaces

Public Vars

jackdaw.streams.extras

FIXME

logging-state-restore-listener

(logging-state-restore-listener)
Returns a new Kafka `StateRestoreListener` instance which logs when
batches are restored, and how long it takes to restore all the
batches for a given partition.
view source

map-validating!

(map-validating! builder topic topic-spec {:keys [line file]})
view source
through
macro
(through builder topic topic-spec)(through builder partition-fn topic topic-spec)
Wraps `#'jackdaw.streams/through`, providing validation of records
against the spec of the through topic.
view source
to!
macro
(to! builder topic topic-spec)(to! builder partition-fn topic topic-spec)
Wraps `#'jackdaw.streams/to!`, providing validation of records
against the spec of the to! topic.
view source
with-file
(with-file form-meta)
view source