kafkajs - npm Package Compare versions

Comparing version 1.13.0-beta.8 to 1.13.0-beta.9

package.json

 {
   "name": "kafkajs",
-  "version": "1.13.0-beta.8",
+  "version": "1.13.0-beta.9",
   "description": "A modern Apache Kafka client for node.js",
@@ -82,5 +82,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "385be119d5290d000e42a488246a599a0796571e",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...385be119d5290d000e42a488246a599a0796571e"
+    "sha": "03409e2af6d8622b5e65c21c63a750cb938a8587",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...03409e2af6d8622b5e65c21c63a750cb938a8587"
   }
 }

src/consumer/consumerGroup.js

@@ -101,3 +101,7 @@ const flatten = require('../utils/flatten')
       memberId: this.memberId || '',
-      groupProtocols: this.assigners.map(assigner => assigner.protocol({ topics: this.topics })),
+      groupProtocols: this.assigners.map(assigner =>
+        assigner.protocol({
+          topics: this.topicsSubscribed,
+        })
+      ),
     })
@@ -104,0 +108,0 @@

No alert changes

Improved metrics

Total package byte prevSize

505289

0.01%

Lines of code

14936

0.03%

No dependency changes