clj-kafka-repl.channel
core.async based functions for use with kafka/consume.
close!
(close! {:keys [channel]})Closes the specified core.async channel.
closed?
(closed? {:keys [channel]})Returns flag indicating whether the specified channel is closed.
poll!
(poll! {:keys [channel]})Reads off the next value (if any) from the specified channel.
progress
(progress {:keys [progress-fn]})Gives an indication of the progress of the given tracked channel on its partitions.
to
multimethod
Provides facilities for piping the content of the tracked channel to a given target.
to-file
(to-file {:keys [channel]} f)Streams the contents of the specified channel to the given file path.
to-stdout
(to-stdout {:keys [channel]})Streams the contents of the specified to stdout.