| Modifier and Type | Method and Description |
|---|---|
List<KafkaHeader> |
KafkaConsumerRecord.headers() |
| Modifier and Type | Method and Description |
|---|---|
List<KafkaHeader> |
KafkaConsumerRecordImpl.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 | Class and Description |
|---|---|
class |
KafkaHeaderImpl
Vert.x Kafka producer record header implementation
|
| Modifier and Type | Method and Description |
|---|---|
List<KafkaHeader> |
KafkaProducerRecordImpl.headers() |
| Modifier and Type | Method and Description |
|---|---|
KafkaProducerRecord<K,V> |
KafkaProducerRecordImpl.addHeader(KafkaHeader header) |
| Modifier and Type | Method and Description |
|---|---|
KafkaProducerRecord<K,V> |
KafkaProducerRecordImpl.addHeaders(List<KafkaHeader> headers) |
| 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 © 2020. All rights reserved.