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

Comparing version 0.3.61 to 0.3.62

dist/rdkafka_json_consumer.js

@@ -50,8 +50,7 @@ /*****
         this._kafkaRawConsumer = new rdkafka_raw_consumer_1.MLKafkaRawConsumer(rawOptions, logger);
-        if (this._options.batchSize && this._options.batchSize > 1) {
-            this._kafkaRawConsumer.setBatchCallbackFn(this._internalBatchHandler.bind(this));
-        }
-        else {
-            this._kafkaRawConsumer.setCallbackFn(this._internalHandler.bind(this));
-        }
+        // if (this._options.batchSize && this._options.batchSize > 1) {
+        //     this._kafkaRawConsumer.setBatchCallbackFn(this._internalBatchHandler.bind(this));
+        // } else {
+        //     this._kafkaRawConsumer.setCallbackFn(this._internalHandler.bind(this));
+        // }
         this._kafkaRawConsumer.eventNames();
@@ -108,2 +107,3 @@ // hook MLKafkaRawConsumer events we care about
         this._handlerCallback = handlerCallback;
+        this._kafkaRawConsumer.setCallbackFn(this._internalHandler.bind(this));
     }
@@ -113,2 +113,3 @@ setBatchCallbackFn(batchHandlerCallback) {
         this._batchHandlerCallback = batchHandlerCallback;
+        this._kafkaRawConsumer.setBatchCallbackFn(this._internalBatchHandler.bind(this));
     }
@@ -115,0 +116,0 @@ setFilteringFn(filterFn) {

package.json

 {
   "name": "@mojaloop/platform-shared-lib-nodejs-kafka-client-lib",
-  "version": "0.3.61",
+  "version": "0.3.62",
   "description": "mojaloop vnext platform shared libraries",
@@ -5,0 +5,0 @@ "license": "Apache-2.0",

No alert changes

Improved metrics

Total package byte prevSize

101219

increased by0.14%

Lines of code

1307

increased by0.08%

No dependency changes