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
.