1 |
|
2 |
|
3 |
|
4 | export 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 | }
|