Merge pull request #5638 from smhmayboudi/5637-feat-improve-KafkaHeaders

feat(microservices): Improve KafkaHeaders
nestjs · Nov 2, 2020 · 62352ac · 62352ac
2 parents b4b7e3a + 8d91534
commit 62352ac
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/packages/microservices/enums/kafka-headers.enum.ts b/packages/microservices/enums/kafka-headers.enum.ts
@@ -6,6 +6,7 @@ export enum KafkaHeaders {
   BATCH_CONVERTED_HEADERS = 'kafka_batchConvertedHeaders',
   CONSUMER = 'kafka_consumer',
   CORRELATION_ID = 'kafka_correlationId',
+  DELIVERY_ATTEMPT = 'kafka_deliveryAttempt',
   DLT_EXCEPTION_FQCN = 'kafka_dlt-exception-fqcn',
   DLT_EXCEPTION_MESSAGE = 'kafka_dlt-exception-message',
   DLT_EXCEPTION_STACKTRACE = 'kafka_dlt-exception-stacktrace',
@@ -14,6 +15,7 @@ export enum KafkaHeaders {
   DLT_ORIGINAL_TIMESTAMP = 'kafka_dlt-original-timestamp',
   DLT_ORIGINAL_TIMESTAMP_TYPE = 'kafka_dlt-original-timestamp-type',
   DLT_ORIGINAL_TOPIC = 'kafka_dlt-original-topic',
+  GROUP_ID = 'kafka_groupId',
   MESSAGE_KEY = 'kafka_messageKey',
   NATIVE_HEADERS = 'kafka_nativeHeaders',
   OFFSET = 'kafka_offset',