UNPKG

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