| Package | Description | 
|---|---|
| io.vertx.rxjava.kafka.client.consumer | |
| io.vertx.rxjava.kafka.client.producer | 
| Modifier and Type | Method and Description | 
|---|---|
List<KafkaHeader> | 
KafkaConsumerRecord.headers()  | 
| Modifier and Type | Field and Description | 
|---|---|
static io.vertx.lang.rx.TypeArg<KafkaHeader> | 
KafkaHeader.__TYPE_ARG  | 
| Modifier and Type | Method and Description | 
|---|---|
static KafkaHeader | 
KafkaHeader.header(String key,
      Buffer value)  | 
static KafkaHeader | 
KafkaHeader.header(String key,
      String value)  | 
static KafkaHeader | 
KafkaHeader.newInstance(KafkaHeader arg)  | 
| Modifier and Type | Method and Description | 
|---|---|
List<KafkaHeader> | 
KafkaProducerRecord.headers()  | 
| Modifier and Type | Method and Description | 
|---|---|
KafkaProducerRecord<K,V> | 
KafkaProducerRecord.addHeader(KafkaHeader header)
Add an header to this record. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
KafkaProducerRecord<K,V> | 
KafkaProducerRecord.addHeaders(List<KafkaHeader> headers)
Add a list of headers to this record. 
 | 
Copyright © 2020 Eclipse. All rights reserved.