@lumigo/node-core - npm Package Compare versions

Comparing version 1.15.1 to 1.16.0

lib/common/triggers/message-trigger.enum.d.ts

@@ -12,3 +12,4 @@ export declare enum MessageTrigger {
     SNS = "sns",
-    S3 = "s3"
+    S3 = "s3",
+    KAFKA = "kafka"
 }

lib/common/triggers/message-trigger.enum.js

@@ -17,3 +17,4 @@ "use strict";
     MessageTrigger["S3"] = "s3";
+    MessageTrigger["KAFKA"] = "kafka";
 })(MessageTrigger = exports.MessageTrigger || (exports.MessageTrigger = {}));
 //# sourceMappingURL=message-trigger.enum.js.map

lib/common/triggers/trigger-data.types.d.ts

@@ -13,2 +13,3 @@ import type { MessageTrigger } from './message-trigger.enum';
     approxEventCreationTime?: number;
+    bootstrapServers?: string;
 }
@@ -15,0 +16,0 @@ export interface Trigger {

lib/common/triggers/triggers.js

@@ -12,2 +12,3 @@ "use strict";
 const sqs_parser_1 = require("./trigger-parsers/sqs-parser");
+const kafka_parser_1 = require("./trigger-parsers/kafka-parser");
 const logger = require("../../logger");
@@ -26,2 +27,3 @@ const configuration_1 = require("../configuration");
     new sqs_parser_1.SqsMessageParser(),
+    new kafka_parser_1.KafkaMessageParser(),
 ];
@@ -28,0 +30,0 @@ exports.INNER_MESSAGES_IDENTIFIER_PATTERN = new RegExp('(' +

package.json

 {
   "name": "@lumigo/node-core",
-  "version": "1.15.1",
+  "version": "1.16.0",
   "description": "Lumigo core node sdk",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

No alert changes

Improved metrics

Total package byte prevSize

232074

increased by3.45%

Number of package files

104

increased by2.97%

Lines of code

2207

increased by3.42%

No dependency changes