KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeader(KafkaHeader header) |
Add an header to this record.
|
KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeader(String key,
Buffer value) |
|
KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeader(String key,
String value) |
|
KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeaders(List<KafkaHeader> headers) |
Add a list of headers to this record.
|
static <K,V> KafkaProducerRecord<K,V> |
KafkaProducerRecord.create(String topic,
K key,
V value) |
Create a concrete instance of a Vert.x producer record
|
static <K,V> KafkaProducerRecord<K,V> |
KafkaProducerRecord.create(String topic,
K key,
V value,
Integer partition) |
Create a concrete instance of a Vert.x producer record
|
static <K,V> KafkaProducerRecord<K,V> |
KafkaProducerRecord.create(String topic,
K key,
V value,
Long timestamp,
Integer partition) |
Create a concrete instance of a Vert.x producer record
|
static <K,V> KafkaProducerRecord<K,V> |
KafkaProducerRecord.create(String topic,
V value) |
Create a concrete instance of a Vert.x producer record
|