(make-producer-options m)
(make-producer-options close-timeout send-callback)
(make-producer-options close-timeout close-timeout-unit send-callback)
Inputs: ([m] [close-timeout send-callback] [close-timeout close-timeout-unit send-callback]) Returns: ps/ProducerOptions
Creates a producer options record.
The default close-timeout-unit if not provided is milliseconds.
Inputs: ([m] [close-timeout send-callback] [close-timeout close-timeout-unit send-callback]) Returns: ps/ProducerOptions Creates a producer options record. The default close-timeout-unit if not provided is milliseconds.
(make-producer-record m)
(make-producer-record topic value)
(make-producer-record topic key value)
(make-producer-record topic partition key value)
Inputs: ([m] [topic value] [topic key value] [topic partition key value]) Returns: ps/ProducerRecord
Creates a producer record (record).
You must provide one of the following:
Inputs: ([m] [topic value] [topic key value] [topic partition key value]) Returns: ps/ProducerRecord Creates a producer record (record). You must provide one of the following: * Topic and Value - Will use partitioner in producer config to decide which partition. * Topic, Partition, Key, Value - Will use explicit arguments. * Topic, Key, Value - Will use the key and partitioner to decide which partition.
(make-record-metadata m)
(make-record-metadata topic partition offset)
Inputs: ([m] [topic partition offset]) Returns: ps/RecordMetadata
Creates a record metadata record.
Inputs: ([m] [topic partition offset]) Returns: ps/RecordMetadata Creates a record metadata record.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close