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 containing the message key when sending data to Kafka.
|
static java.lang.String |
OFFSET
The header for partition offset.
|
static java.lang.String |
PARTITION_ID
The header containing the topic partition when sending data to Kafka.
|
static java.lang.String |
RECEIVED_MESSAGE_KEY
The header containing the message key for the received message.
|
static java.lang.String |
RECEIVED_PARTITION_ID
The header containing the topic partition for the received message.
|
static java.lang.String |
RECEIVED_TOPIC
The header containing the topic from which the message was received.
|
static java.lang.String |
TOPIC
The header containing the topic when sending data to Kafka.
|
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
.public static final java.lang.String RECEIVED_TOPIC
public static final java.lang.String RECEIVED_MESSAGE_KEY
public static final java.lang.String RECEIVED_PARTITION_ID