kafkajs - npm Package Compare versions

Comparing version 1.15.0-beta.10 to 1.15.0-beta.11

package.json

 {
   "name": "kafkajs",
-  "version": "1.15.0-beta.10",
+  "version": "1.15.0-beta.11",
   "description": "A modern Apache Kafka client for node.js",
@@ -83,5 +83,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "9052b0873334a3378c5a4d6a07d845c2fc48ad0e",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...9052b0873334a3378c5a4d6a07d845c2fc48ad0e"
+    "sha": "f9dafb53b6303991e745959e6eef4f8384f0aacd",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...f9dafb53b6303991e745959e6eef4f8384f0aacd"
   }
 }

src/producer/index.js

@@ -237,3 +237,3 @@ const createRetry = require('../retry')
       await cluster.disconnect()
-      connectionStatus = CONNECTION_STATUS.DISCONNECT
+      connectionStatus = CONNECTION_STATUS.DISCONNECTED
       instrumentationEmitter.emit(DISCONNECT)
@@ -240,0 +240,0 @@ },

No alert changes

Improved metrics

Total package byte prevSize

636459

0

No dependency changes