Run consume logic in a separate thread

Blizzard · Jan 20, 2023 · d521e0f · d521e0f
2 parents 52b40e9 + e7dc75d
commit d521e0f
Show file tree

Hide file tree

Showing 7 changed files with 314 additions and 194 deletions.
diff --git a/lib/kafka-consumer.js b/lib/kafka-consumer.js
@@ -385,7 +385,7 @@ KafkaConsumer.prototype.unsubscribe = function() {
  * is fetched.
  */
 KafkaConsumer.prototype.consume = function(number, cb) {
-  var timeoutMs = this._consumeTimeout || DEFAULT_CONSUME_TIME_OUT;
+  var timeoutMs = this._consumeTimeout !== undefined ? this._consumeTimeout : DEFAULT_CONSUME_TIME_OUT;
   var self = this;
 
   if ((number && typeof number === 'number') || (number && cb)) {