kafka-clj.produce — kafka-clj 4.0.3

API_KEY_FETCH_REQUEST clj

API_KEY_OFFSET_REQUEST clj

API_KEY_PRODUCE_REQUEST clj

API_VERSION clj

flush-on-byte->fn clj

(flush-on-byte->fn byte-limit)

Returns a check-f for buffered-chan that will flush if the accumulated byte count is bigger than that of byte-limit

MAGIC_BYTE clj

message clj

(message topic partition bts)

shutdown clj

(shutdown {:keys [client]})

write-compressed-message-set clj

(write-compressed-message-set buff correlation-id codec msgs)

Writes the compressed message and returns a tuple of [offset msgs]

write-message clj

(write-message buff codec bts)

write-message-for-ack clj

(write-message-for-ack cache-ctx conf msgs buff)

Writes the messages to the buff and send the results of [[offset msgs] ...] to the cache. This function always returns the msgs

write-message-set clj

(write-message-set buff correlation-id codec msgs)

Writes a message set and returns a tuple of [first-offset msgs]

write-request clj

(write-request buff
               {:keys [client-id codec acks timeout]
                :or {client-id "1" codec 0 acks 1 timeout 1000}
                :as conf}
               msgs)

Writes the messages and return a sequence of [ [offset msgs] ... ] The offset is the first offset in the message set For compressed messages this is the uncompressed message, and allows us to retry message sending.