kafkajs - npm Package Compare versions

Comparing version 1.11.0-beta.5 to 1.11.0-beta.6

package.json

 {
   "name": "kafkajs",
-  "version": "1.11.0-beta.5",
+  "version": "1.11.0-beta.6",
   "description": "A modern Apache Kafka client for node.js",
@@ -81,5 +81,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "8feb245268c462ce5a08de1951e0892c076d120f",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.10.0...8feb245268c462ce5a08de1951e0892c076d120f"
+    "sha": "e21c04dd114e5819309f77c1429063813c08cbed",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.10.0...e21c04dd114e5819309f77c1429063813c08cbed"
   }
 }

src/consumer/index.js

@@ -148,2 +148,6 @@ const Long = require('long')
   const subscribe = async ({ topic, fromBeginning = false }) => {
+    if (consumerGroup) {
+      throw new KafkaJSNonRetriableError('Cannot subscribe to topic while consumer is running')
+    }
+
     if (!topic) {
@@ -150,0 +154,0 @@ throw new KafkaJSNonRetriableError(`Invalid topic ${topic}`)

No alert changes

Improved metrics

Total package byte prevSize

471245

increased by0.03%

Lines of code

14004

increased by0.02%

No dependency changes