Package | Description |
---|---|
io.vertx.kafka.client.consumer | |
io.vertx.kafka.client.producer | |
io.vertx.reactivex.kafka.client.producer | |
io.vertx.rxjava.kafka.client.producer |
Modifier and Type | Method and Description |
---|---|
List<KafkaHeader> |
KafkaConsumerRecord.headers() |
Modifier and Type | Method and Description |
---|---|
static KafkaHeader |
KafkaHeader.header(String key,
Buffer value) |
static KafkaHeader |
KafkaHeader.header(String key,
byte[] value) |
static KafkaHeader |
KafkaHeader.header(String key,
String value) |
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.
|
Modifier and Type | Method and Description |
---|---|
KafkaHeader |
KafkaHeader.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static KafkaHeader |
KafkaHeader.newInstance(KafkaHeader arg) |
Constructor and Description |
---|
KafkaHeader(KafkaHeader delegate) |
Modifier and Type | Method and Description |
---|---|
KafkaHeader |
KafkaHeader.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static KafkaHeader |
KafkaHeader.newInstance(KafkaHeader arg) |
Constructor and Description |
---|
KafkaHeader(KafkaHeader delegate) |
Copyright © 2021 Eclipse. All rights reserved.