jackdaw.streams.extras — fundingcircle/jackdaw 0.7.2

FIXME

logging-state-restore-listener clj

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

map-validating! clj

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

through clj 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.

to! clj 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.

with-file clj

(with-file form-meta)