Liking cljdoc? Tell your friends :D
franzy.clients.producer.types
make-producer-optionsclj
(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-recordclj
(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:
- 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.
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-metadataclj
(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