Liking cljdoc? Tell your friends :D

ketu.clients.producer


byte-array-serializerclj

(byte-array-serializer)
source

callbackclj

(callback f)
source

close!clj

(close! producer timeout-ms)
source

flush!clj

(flush! producer)
source

producerclj

(producer config)
(producer config key-serializer value-serializer)

The single param version assumes key and value serializer classes in config.

The single param version assumes key and value serializer classes in config.
sourceraw docstring

recordclj

(record topic value)
(record topic key value)
(record topic partition timestamp key value headers)

Creates a ProducerRecord. We support the basic overloads: [topic value] for value only, [topic key value] for partition by key, [topic partition timestamp key value headers] for manual partition/timestamp or headers. Pass nil if irrelevant.

Creates a ProducerRecord.
We support the basic overloads:
[topic value] for value only,
[topic key value] for partition by key,
[topic partition timestamp key value headers] for manual partition/timestamp or headers. Pass nil if irrelevant.
sourceraw docstring

send!clj

(send! producer record)
(send! producer record callback)

For convenience, create producer, record and callback with the respective clojure functions in this namespace. Callback may be nil.

For convenience, create producer, record and callback with the respective clojure functions in this namespace.
Callback may be nil.
sourceraw docstring

string-serializerclj

(string-serializer)
source

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

× close