(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.
(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.
(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.
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 |