public final class KafkaMetadataKeys extends Object
Modifier and Type | Field and Description |
---|---|
static MetadataKey<org.apache.kafka.common.header.Headers> |
HEADERS
The Kafka message headers.
|
static MetadataKey<Long> |
OFFSET
The offset of the message in its partition.
|
static MetadataKey<Integer> |
PARTITION
The partition the message is published to.
|
static MetadataKey<Long> |
TIMESTAMP
The timestamp of the Kafka message.
|
static MetadataKey<org.apache.kafka.common.record.TimestampType> |
TIMESTAMP_TYPE
The timestamp type of the Kafka message.
|
static MetadataKey<String> |
TOPIC
The topic the message is published to.
|
public static final MetadataKey<Integer> PARTITION
public static final MetadataKey<Long> OFFSET
public static final MetadataKey<String> TOPIC
public static final MetadataKey<org.apache.kafka.common.header.Headers> HEADERS
public static final MetadataKey<Long> TIMESTAMP
public static final MetadataKey<org.apache.kafka.common.record.TimestampType> TIMESTAMP_TYPE