Liking cljdoc? Tell your friends :D
jackdaw.streams.extras
FIXME
FIXME
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.
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.
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.
with-fileclj
(with-file form-meta)cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close