Liking cljdoc? Tell your friends :D

jackdaw.streams.extras

FIXME

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.

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.
sourceraw docstring

map-validating!

(map-validating! builder topic topic-spec {:keys [line file]})
source

throughmacro

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

Wraps `#'jackdaw.streams/through`, providing validation of records
against the spec of the through topic.
sourceraw docstring

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.

Wraps `#'jackdaw.streams/to!`, providing validation of records
against the spec of the to! topic.
sourceraw docstring

with-file

(with-file form-meta)
source

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

× close