new KafkaProducerRecord()
Vert.x Kafka producer record.
Methods
addHeader(header) → {KafkaProducerRecord}
Add an header to this record.
Parameters:
| Name | Type | Description |
|---|---|---|
header |
KafkaHeader | the header |
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 |
Returns:
current KafkaProducerRecord instance
- Type
- KafkaProducerRecord
headers() → {Array.<KafkaHeader>}
Returns:
the headers of this record
- Type
- Array.<KafkaHeader>
key() → {Object}
Returns:
the key (or null if no key is specified)
- Type
- Object
partition() → {number}
Returns:
the partition to which the record will be sent (or null if no partition was specified)
- Type
- number
timestamp() → {number}
Returns:
the timestamp of this record
- Type
- number
topic() → {string}
Returns:
the topic this record is being sent to
- Type
- string
value() → {Object}
Returns:
the value
- Type
- Object