public abstract class KafkaHeaders
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
ACKNOWLEDGMENT
The header for
Acknowledgment. |
static java.lang.String |
MESSAGE_KEY
The header for message key.
|
static java.lang.String |
OFFSET
The header for partition offset.
|
static java.lang.String |
PARTITION_ID
The header for topic partition.
|
static java.lang.String |
TOPIC
The header for topic.
|
| Constructor and Description |
|---|
KafkaHeaders() |
public static final java.lang.String TOPIC
public static final java.lang.String MESSAGE_KEY
public static final java.lang.String PARTITION_ID
public static final java.lang.String OFFSET
public static final java.lang.String ACKNOWLEDGMENT
Acknowledgment.