no-kafka - npm Package Compare versions

Comparing version 3.4.3 to 3.4.4

lib/group_consumer.js

@@ -324,2 +324,3 @@ 'use strict';
             if (p.error || p.offset < 0) {
+                self.client.warn('No commited offset available, time set to startingOffset for', p.topic + ':' + p.partition);
                 options = {
@@ -326,0 +327,0 @@ time: self.options.startingOffset

package.json

@@ -9,3 +9,3 @@ {
   },
-  "version": "3.4.3",
+  "version": "3.4.4",
   "main": "./lib/index.js",
@@ -21,3 +21,3 @@ "types": "./types/index.d.ts",
     "hashring": "^3.2.0",
-    "lodash": "=4.17.11",
+    "lodash": "=4.17.21",
     "murmur-hash-js": "^1.0.0",
@@ -24,0 +24,0 @@ "nice-simple-logger": "^1.0.1",

types/base_consumer.d.ts

@@ -11,2 +11,4 @@ import * as Kafka from "./kafka";
         handler: DataHandler): Promise<void>;
+    subscribe(topic: string, options: BaseConsumerOptions, handler: DataHandler): Promise<void>;
+    subscribe(topic: string, handler: DataHandler): Promise<void>;
 
@@ -13,0 +15,0 @@ unsubscribe(topic: string, partitions?: number | number[]): Promise<number[]>;

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Lines of code

6000

increased by0.05%

Worsened metrics

Total package byte prevSize

361999

decreased by-2.5%

Dependency changes

• Updatedlodash@=4.17.21