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-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
(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-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-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-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 builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |