kafka-clj.msg-persist — kafka-clj 4.0.3

_create-retry-cache clj

(_create-retry-cache {:keys [retry-cache-file retry-cache-delete-on-exit]
                      :or {retry-cache-delete-on-exit false
                           retry-cache-file "/tmp/kafka-retry-cache"}})

_it_next clj

(_it_next it)

_map-values-seq clj

(_map-values-seq it)

cache-sent-messages clj

(cache-sent-messages {:keys [send-cache]} offsets)

Offsets is expected to have format [[corr-id msgs]...] msgs is a list of messages (of maps with keys topic partition), and corr-id a long value For any msgs sequence all messages must be from the same partition.

close-retry-cache clj

(close-retry-cache _)

closed? clj

(closed? {{:keys [db]} :retry-cache})

create-retry-cache clj

(create-retry-cache {:keys [retry-cache-file]
                     :or {retry-cache-file (str (tmp-dir) "/kafka-retry-cache")}
                     :as conf})

create-send-cache clj

(create-send-cache {:keys [send-cache-size-limit send-cache-max-entries
                           send-cache-expire-after-write
                           send-cache-expire-after-access]
                    :or {send-cache-size-limit 4
                         send-cache-max-entries 2000000
                         send-cache-expire-after-write 5
                         send-cache-expire-after-access 5}})

delete-from-retry-cache clj

(delete-from-retry-cache {:keys [retry-cache]} key-val)

get-sent-message clj

(get-sent-message {:keys [send-cache]} topic partition corr-id)

map-values clj

(map-values m)

retry-cache-seq clj

(retry-cache-seq {:keys [retry-cache] :as connector})

tmp-dir clj

(tmp-dir)

write-to-retry-cache clj

(write-to-retry-cache {:keys [retry-cache]} topic v)