UNPKG

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