Liking cljdoc? Tell your friends :D

jackdaw.streams.extras

FIXME

FIXME
raw docstring

logging-state-restore-listenerclj

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

map-validating!clj

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

throughcljmacro

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

to!cljmacro

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

with-fileclj

(with-file form-meta)

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

× close