UNPKG

2.4 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 */
7var KafkaHeaders;
8(function (KafkaHeaders) {
9 KafkaHeaders["ACKNOWLEDGMENT"] = "kafka_acknowledgment";
10 KafkaHeaders["BATCH_CONVERTED_HEADERS"] = "kafka_batchConvertedHeaders";
11 KafkaHeaders["CONSUMER"] = "kafka_consumer";
12 KafkaHeaders["CORRELATION_ID"] = "kafka_correlationId";
13 KafkaHeaders["DELIVERY_ATTEMPT"] = "kafka_deliveryAttempt";
14 KafkaHeaders["DLT_EXCEPTION_FQCN"] = "kafka_dlt-exception-fqcn";
15 KafkaHeaders["DLT_EXCEPTION_MESSAGE"] = "kafka_dlt-exception-message";
16 KafkaHeaders["DLT_EXCEPTION_STACKTRACE"] = "kafka_dlt-exception-stacktrace";
17 KafkaHeaders["DLT_ORIGINAL_OFFSET"] = "kafka_dlt-original-offset";
18 KafkaHeaders["DLT_ORIGINAL_PARTITION"] = "kafka_dlt-original-partition";
19 KafkaHeaders["DLT_ORIGINAL_TIMESTAMP"] = "kafka_dlt-original-timestamp";
20 KafkaHeaders["DLT_ORIGINAL_TIMESTAMP_TYPE"] = "kafka_dlt-original-timestamp-type";
21 KafkaHeaders["DLT_ORIGINAL_TOPIC"] = "kafka_dlt-original-topic";
22 KafkaHeaders["GROUP_ID"] = "kafka_groupId";
23 KafkaHeaders["MESSAGE_KEY"] = "kafka_messageKey";
24 KafkaHeaders["NATIVE_HEADERS"] = "kafka_nativeHeaders";
25 KafkaHeaders["OFFSET"] = "kafka_offset";
26 KafkaHeaders["PARTITION_ID"] = "kafka_partitionId";
27 KafkaHeaders["PREFIX"] = "kafka_";
28 KafkaHeaders["RAW_DATA"] = "kafka_data";
29 KafkaHeaders["RECEIVED"] = "kafka_received";
30 KafkaHeaders["RECEIVED_MESSAGE_KEY"] = "kafka_receivedMessageKey";
31 KafkaHeaders["RECEIVED_PARTITION_ID"] = "kafka_receivedPartitionId";
32 KafkaHeaders["RECEIVED_TIMESTAMP"] = "kafka_receivedTimestamp";
33 KafkaHeaders["RECEIVED_TOPIC"] = "kafka_receivedTopic";
34 KafkaHeaders["RECORD_METADATA"] = "kafka_recordMetadata";
35 KafkaHeaders["REPLY_PARTITION"] = "kafka_replyPartition";
36 KafkaHeaders["REPLY_TOPIC"] = "kafka_replyTopic";
37 KafkaHeaders["TIMESTAMP"] = "kafka_timestamp";
38 KafkaHeaders["TIMESTAMP_TYPE"] = "kafka_timestampType";
39 KafkaHeaders["TOPIC"] = "kafka_topic";
40 // framework specific headers
41 KafkaHeaders["NEST_ERR"] = "kafka_nest-err";
42 KafkaHeaders["NEST_IS_DISPOSED"] = "kafka_nest-is-disposed";
43})(KafkaHeaders = exports.KafkaHeaders || (exports.KafkaHeaders = {}));