UNPKG

1.65 kBTypeScriptView Raw
1/**
2 * @see https://docs.spring.io/spring-kafka/api/org/springframework/kafka/support/KafkaHeaders.html
3 */
4export declare enum KafkaHeaders {
5 ACKNOWLEDGMENT = "kafka_acknowledgment",
6 BATCH_CONVERTED_HEADERS = "kafka_batchConvertedHeaders",
7 CONSUMER = "kafka_consumer",
8 CORRELATION_ID = "kafka_correlationId",
9 DELIVERY_ATTEMPT = "kafka_deliveryAttempt",
10 DLT_EXCEPTION_FQCN = "kafka_dlt-exception-fqcn",
11 DLT_EXCEPTION_MESSAGE = "kafka_dlt-exception-message",
12 DLT_EXCEPTION_STACKTRACE = "kafka_dlt-exception-stacktrace",
13 DLT_ORIGINAL_OFFSET = "kafka_dlt-original-offset",
14 DLT_ORIGINAL_PARTITION = "kafka_dlt-original-partition",
15 DLT_ORIGINAL_TIMESTAMP = "kafka_dlt-original-timestamp",
16 DLT_ORIGINAL_TIMESTAMP_TYPE = "kafka_dlt-original-timestamp-type",
17 DLT_ORIGINAL_TOPIC = "kafka_dlt-original-topic",
18 GROUP_ID = "kafka_groupId",
19 MESSAGE_KEY = "kafka_messageKey",
20 NATIVE_HEADERS = "kafka_nativeHeaders",
21 OFFSET = "kafka_offset",
22 PARTITION_ID = "kafka_partitionId",
23 PREFIX = "kafka_",
24 RAW_DATA = "kafka_data",
25 RECEIVED = "kafka_received",
26 RECEIVED_MESSAGE_KEY = "kafka_receivedMessageKey",
27 RECEIVED_PARTITION_ID = "kafka_receivedPartitionId",
28 RECEIVED_TIMESTAMP = "kafka_receivedTimestamp",
29 RECEIVED_TOPIC = "kafka_receivedTopic",
30 RECORD_METADATA = "kafka_recordMetadata",
31 REPLY_PARTITION = "kafka_replyPartition",
32 REPLY_TOPIC = "kafka_replyTopic",
33 TIMESTAMP = "kafka_timestamp",
34 TIMESTAMP_TYPE = "kafka_timestampType",
35 TOPIC = "kafka_topic",
36 NEST_ERR = "kafka_nest-err",
37 NEST_IS_DISPOSED = "kafka_nest-is-disposed"
38}