public abstract class KafkaHeaders
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ACKNOWLEDGMENT
The header for the
Acknowledgment . |
static java.lang.String |
BATCH_CONVERTED_HEADERS
The header for a list of Maps of converted native Kafka headers.
|
static java.lang.String |
CONSUMER
The header for the
Consumer object. |
static java.lang.String |
CORRELATION_ID
The header containing information to correlate requests/replies.
|
static java.lang.String |
DLT_EXCEPTION_FQCN
Exception class name for a record published sent to a dead-letter topic.
|
static java.lang.String |
DLT_EXCEPTION_MESSAGE
Exception message for a record published to a dead-letter topic.
|
static java.lang.String |
DLT_EXCEPTION_STACKTRACE
Exception stack trace for a record published to a dead-letter topic.
|
static java.lang.String |
DLT_ORIGINAL_OFFSET
Original offset for a record published to a dead-letter topic.
|
static java.lang.String |
DLT_ORIGINAL_PARTITION
Original partition for a record published to a dead-letter topic.
|
static java.lang.String |
DLT_ORIGINAL_TIMESTAMP
Original timestamp for a record published to a dead-letter topic.
|
static java.lang.String |
DLT_ORIGINAL_TIMESTAMP_TYPE
Original timestamp type for a record published to a dead-letter topic.
|
static java.lang.String |
DLT_ORIGINAL_TOPIC
Original topic for a record published to a dead-letter topic.
|
static java.lang.String |
GROUP_ID
For inbound messages, the container's
group.id consumer property. |
static java.lang.String |
MESSAGE_KEY
The header containing the message key when sending data to Kafka.
|
static java.lang.String |
NATIVE_HEADERS
The header for holding the native headers of the consumer record; only provided
if no header mapper is present.
|
static java.lang.String |
OFFSET
The header for the partition offset.
|
static java.lang.String |
PARTITION_ID
The header containing the topic partition when sending data to Kafka.
|
static java.lang.String |
PREFIX
The prefix for Kafka headers.
|
static java.lang.String |
RAW_DATA
The header containing the raw data received from Kafka (
ConsumerRecord or
ConsumerRecords ). |
static java.lang.String |
RECEIVED
The prefix for Kafka headers containing 'received' values.
|
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_TIMESTAMP
The header for holding the timestamp of the consumer record.
|
static java.lang.String |
RECEIVED_TOPIC
The header containing the topic from which the message was received.
|
static java.lang.String |
RECORD_METADATA
The header containing the
RecordMetadata object after successful send to the topic. |
static java.lang.String |
REPLY_PARTITION
The header containing a partition number on which to send the reply.
|
static java.lang.String |
REPLY_TOPIC
The header containing the default reply topic.
|
static java.lang.String |
TIMESTAMP
The header for holding the timestamp of the producer record.
|
static java.lang.String |
TIMESTAMP_TYPE
The header for holding the
type of timestamp. |
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 PREFIX
public static final java.lang.String RECEIVED
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 RAW_DATA
ConsumerRecord
or
ConsumerRecords
). Usually used to enhance error messages.public static final java.lang.String RECORD_METADATA
RecordMetadata
object after successful send to the topic.public static final java.lang.String ACKNOWLEDGMENT
Acknowledgment
.public static final java.lang.String CONSUMER
Consumer
object.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
public static final java.lang.String TIMESTAMP_TYPE
type
of timestamp.public static final java.lang.String TIMESTAMP
public static final java.lang.String RECEIVED_TIMESTAMP
public static final java.lang.String NATIVE_HEADERS
public static final java.lang.String BATCH_CONVERTED_HEADERS
public static final java.lang.String CORRELATION_ID
public static final java.lang.String REPLY_TOPIC
public static final java.lang.String REPLY_PARTITION
public static final java.lang.String DLT_EXCEPTION_FQCN
public static final java.lang.String DLT_EXCEPTION_STACKTRACE
public static final java.lang.String DLT_EXCEPTION_MESSAGE
public static final java.lang.String DLT_ORIGINAL_TOPIC
public static final java.lang.String DLT_ORIGINAL_PARTITION
public static final java.lang.String DLT_ORIGINAL_OFFSET
public static final java.lang.String DLT_ORIGINAL_TIMESTAMP
public static final java.lang.String DLT_ORIGINAL_TIMESTAMP_TYPE
public static final java.lang.String GROUP_ID
group.id
consumer property.