| Package | Description | 
|---|---|
| io.vertx.kafka.client.producer | |
| io.vertx.reactivex.kafka.client.producer | |
| io.vertx.rxjava.kafka.client.producer | |
| io.vertx.rxjava3.kafka.client.producer | 
| Modifier and Type | Method and Description | 
|---|---|
KafkaProducerRecord<K,V> | 
KafkaProducerRecord.addHeader(KafkaHeader header)
Add an header to this record. 
 | 
KafkaProducerRecord<K,V> | 
KafkaProducerRecord.addHeader(String key,
         Buffer value)
Like  
addHeader(KafkaHeader) but with a key/value pair | 
KafkaProducerRecord<K,V> | 
KafkaProducerRecord.addHeader(String key,
         String value)
Like  
addHeader(KafkaHeader) but with a key/value pair | 
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 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Future<RecordMetadata> | 
KafkaProducer.send(KafkaProducerRecord<K,V> record)
Asynchronously write a record to a topic 
 | 
KafkaProducer<K,V> | 
KafkaProducer.send(KafkaProducerRecord<K,V> record,
    Handler<AsyncResult<RecordMetadata>> handler)
Asynchronously write a record to a topic 
 | 
| Modifier and Type | Method and Description | 
|---|---|
KafkaProducerRecord | 
KafkaProducerRecord.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static <K,V> KafkaProducerRecord<K,V> | 
KafkaProducerRecord.newInstance(KafkaProducerRecord arg)  | 
static <K,V> KafkaProducerRecord<K,V> | 
KafkaProducerRecord.newInstance(KafkaProducerRecord arg,
           io.vertx.lang.rx.TypeArg<K> __typeArg_K,
           io.vertx.lang.rx.TypeArg<V> __typeArg_V)  | 
| Constructor and Description | 
|---|
KafkaProducerRecord(KafkaProducerRecord delegate)  | 
| Modifier and Type | Method and Description | 
|---|---|
KafkaProducerRecord | 
KafkaProducerRecord.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static <K,V> KafkaProducerRecord<K,V> | 
KafkaProducerRecord.newInstance(KafkaProducerRecord arg)  | 
static <K,V> KafkaProducerRecord<K,V> | 
KafkaProducerRecord.newInstance(KafkaProducerRecord arg,
           io.vertx.lang.rx.TypeArg<K> __typeArg_K,
           io.vertx.lang.rx.TypeArg<V> __typeArg_V)  | 
| Constructor and Description | 
|---|
KafkaProducerRecord(KafkaProducerRecord delegate)  | 
| Modifier and Type | Method and Description | 
|---|---|
KafkaProducerRecord | 
KafkaProducerRecord.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static <K,V> KafkaProducerRecord<K,V> | 
KafkaProducerRecord.newInstance(KafkaProducerRecord arg)  | 
static <K,V> KafkaProducerRecord<K,V> | 
KafkaProducerRecord.newInstance(KafkaProducerRecord arg,
           io.vertx.lang.rx.TypeArg<K> __typeArg_K,
           io.vertx.lang.rx.TypeArg<V> __typeArg_V)  | 
| Constructor and Description | 
|---|
KafkaProducerRecord(KafkaProducerRecord delegate)  | 
Copyright © 2021 Eclipse. All rights reserved.