@mojaloop/platform-shared-lib-nodejs-kafka-client-lib - npm Package Compare versions

Comparing version 0.3.71 to 0.5.1

dist/raw/rdkafka_raw_consumer.js

@@ -50,11 +50,26 @@ /*****
 class MLKafkaRawConsumerOptions {
+    kafkaBrokerList;
+    kafkaGroupId;
+    consumerClientId;
+    useSyncCommit;
+    outputType;
+    autoOffsetReset; // default is latest
+    messageMaxBytes;
+    sessionTimeoutMs; //Client group session and failure detection timeout, default is 45 secs
+    batchSize;
+    batchTimeoutMs;
 }
 exports.MLKafkaRawConsumerOptions = MLKafkaRawConsumerOptions;
 class MLKafkaRawConsumer extends events_1.EventEmitter {
+    _logger;
+    _options;
+    _globalConfig;
+    _topicConfig;
+    _topics;
+    _client;
+    _handlerCallback = null;
+    _batchHandlerCallback = null;
+    _batchSize = defaultOptions.batchSize;
     constructor(options, logger = null) {
         super();
-        this._handlerCallback = null;
-        this._batchHandlerCallback = null;
-        this._batchSize = defaultOptions.batchSize;
-        this._consuming = false;
         this._options = options;
@@ -199,2 +214,3 @@ this._logger = logger;
     }
+    _consuming = false;
     _consumeLoop() {
@@ -201,0 +217,0 @@ if (!this._client.isConnected() || this._consuming)

dist/raw/rdkafka_raw_producer.js

@@ -54,2 +54,9 @@ /*****
 class MLKafkaRawProducerOptions {
+    kafkaBrokerList;
+    producerClientId;
+    skipAcknowledgements;
+    messageMaxBytes;
+    compressionCodec;
+    compressionLevel;
+    partitioner;
 }
@@ -62,2 +69,8 @@ exports.MLKafkaRawProducerOptions = MLKafkaRawProducerOptions;
 class MLKafkaRawProducer extends events_1.EventEmitter {
+    _logger;
+    _client;
+    _globalConfig;
+    _topicConfig;
+    _options;
+    _deliveryReportHandlerFn = null;
     /*    // synthetic sugar for type events
@@ -77,3 +90,2 @@ public on<K extends keyof MLKafkaRawProducerEventListenerMap>(e: K, listener: MLKafkaRawProducerEventListenerMap[K]): this {
         super();
-        this._deliveryReportHandlerFn = null;
         this._options = options;
@@ -80,0 +92,0 @@ this._logger = logger;

dist/rdkafka_json_consumer.js

@@ -36,9 +36,20 @@ /*****
 class MLKafkaJsonConsumerOptions {
+    kafkaBrokerList;
+    kafkaGroupId;
+    useSyncCommit;
+    autoOffsetReset; // default is latest
+    sessionTimeoutMs; //Client group session and failure detection timeout, default is 45 secs
+    batchSize;
+    batchTimeoutMs;
 }
 exports.MLKafkaJsonConsumerOptions = MLKafkaJsonConsumerOptions;
 class MLKafkaJsonConsumer extends events_1.EventEmitter {
+    _logger;
+    _kafkaRawConsumer;
+    _handlerCallback = null;
+    _batchHandlerCallback = null;
+    _filterFn;
+    _options;
     constructor(options, logger = null) {
         super();
-        this._handlerCallback = null;
-        this._batchHandlerCallback = null;
         this._options = options;
@@ -45,0 +56,0 @@ this._logger = logger;

dist/rdkafka_json_producer.js

@@ -35,2 +35,4 @@ /*****
 class MLKafkaJsonProducer {
+    _logger;
+    _rawKafkaProducer;
     constructor(options, logger = null) {
@@ -37,0 +39,0 @@ this._logger = logger;

package.json

 {
     "name": "@mojaloop/platform-shared-lib-nodejs-kafka-client-lib",
-    "version": "0.3.71",
+    "version": "0.5.1",
     "description": "mojaloop vnext platform shared libraries",
@@ -40,13 +40,17 @@ "license": "Apache-2.0",
     "dependencies": {
-        "@mojaloop/logging-bc-public-types-lib": "^0.1.22",
-        "@mojaloop/platform-shared-lib-messaging-types-lib": "~0.2.102",
+        "@mojaloop/logging-bc-public-types-lib": "~0.5.0",
+        "@mojaloop/platform-shared-lib-messaging-types-lib": "~0.5.0",
         "node-rdkafka": "~2.18.0"
     },
     "devDependencies": {
-        "eslint": "^8.53.0",
+        "eslint": "^8.55.0",
         "jest": "^29.7.0",
-        "npm-check-updates": "^16.14.6",
+        "npm-check-updates": "^16.14.11",
         "ts-jest": "^29.1.1",
-        "typescript": "^4.6.4"
+        "typescript": "^4.6.4",
+        "tslib": "^2.6.2"
+    },
+    "engines": {
+        "node": ">=20.10.0"
     }
 }

No alert changes

Improved metrics

Total package byte prevSize

104216

increased by1.65%

Lines of code

1365

increased by3.1%

Worsened metrics

Dev dependency count

6

increased by20%

Dependency changes

• + Added@mojaloop/logging-bc-public-types-lib@0.5.4(transitive)

• + Added@mojaloop/platform-shared-lib-messaging-types-lib@0.5.7(transitive)

• - Removed@mojaloop/logging-bc-public-types-lib@0.1.23(transitive)

• - Removed@mojaloop/platform-shared-lib-messaging-types-lib@0.2.103(transitive)

• Updated@mojaloop/logging-bc-public-types-lib@~0.5.0

• Updated@mojaloop/platform-shared-lib-messaging-types-lib@~0.5.0