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.
raw docstring

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
raw docstring

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.
raw docstring

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.
raw docstring

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.
raw docstring

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.
raw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close