fix: use proper callback param

Blizzard · Mar 25, 2024 · 95c02dc · 95c02dc
1 parent 067755e
commit 95c02dc
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/kafka-consumer.js b/lib/kafka-consumer.js
@@ -416,7 +416,9 @@ KafkaConsumer.prototype.consume = function(number, topic, partition, cb) {
     }
 
     this._consumeNumOfPartition(timeoutMs, number, topic, partition, cb);
-  } else if ((number && typeof number === 'number') || (number && cb)) {
+  } else if ((number && typeof number === 'number') || (number && topic)) {
+    // topic is given as the cb
+    cb = topic;
 
     if (cb === undefined) {
       cb = function() {};