Class: KafkaProducerRecord

vertx-kafka-client-js/kafka_producer_record~ KafkaProducerRecord

new KafkaProducerRecord()

Vert.x Kafka producer record.
Source:

Methods

addHeader(header) → {KafkaProducerRecord}

Add an header to this record.
Parameters:
Name Type Description
header KafkaHeader the header
Source:
Returns:
current KafkaProducerRecord instance
Type
KafkaProducerRecord

addHeaders(headers) → {KafkaProducerRecord}

Add a list of headers to this record.
Parameters:
Name Type Description
headers Array.<KafkaHeader> the headers
Source:
Returns:
current KafkaProducerRecord instance
Type
KafkaProducerRecord

headers() → {Array.<KafkaHeader>}

Source:
Returns:
the headers of this record
Type
Array.<KafkaHeader>

key() → {Object}

Source:
Returns:
the key (or null if no key is specified)
Type
Object

partition() → {number}

Source:
Returns:
the partition to which the record will be sent (or null if no partition was specified)
Type
number

timestamp() → {number}

Source:
Returns:
the timestamp of this record
Type
number

topic() → {string}

Source:
Returns:
the topic this record is being sent to
Type
string

value() → {Object}

Source:
Returns:
the value
Type
Object