Liking cljdoc? Tell your friends :D
jackdaw.client.log
Extras for jackdaw.client for treating topics as seqs of records.
Pretty handy for testing.
Extras for `jackdaw.client` for treating topics as seqs of records. Pretty handy for testing.
count-messagesclj
(count-messages config topic)Consumes all of the messages on a topic to determine the current count
Consumes all of the messages on a topic to determine the current count
logclj
(log consumer polling-interval-ms)(log consumer polling-interval-ms fuse-fn)Given a consumer, returns a lazy sequence of datafied consumer records.
If fuse-fn was provided, stops after fuse-fn returns false.
Given a consumer, returns a lazy sequence of datafied consumer records. If fuse-fn was provided, stops after fuse-fn returns false.
log-untilclj
(log-until consumer polling-interval-ms end-at-ms)Given a consumer, a number of MS at which to poll and a duration, returns a lazy sequence of datafied consumer records consumed during that period.
Stops when current time > end-at.
Given a consumer, a number of MS at which to poll and a duration, returns a lazy sequence of datafied consumer records consumed during that period. Stops when current time > end-at.
log-until-inactivityclj
(log-until-inactivity consumer polling-interval-ms)Given a consumer, returns a lazy sequence of datafied consumer records.
Stops when no messages are returned from poll.
Given a consumer, returns a lazy sequence of datafied consumer records. Stops when no messages are returned from poll.
wait-for-inactivityclj
(wait-for-inactivity config topic inactivity-ms)Waits until no messages have been produced on the topic in the given duration.
Waits until no messages have been produced on the topic in the given duration.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close