diff --git a/packages/nodejs-kafka-client-lib/src/raw/rdkafka_raw_consumer.ts b/packages/nodejs-kafka-client-lib/src/raw/rdkafka_raw_consumer.ts index f2d29b7..cc70702 100644 --- a/packages/nodejs-kafka-client-lib/src/raw/rdkafka_raw_consumer.ts +++ b/packages/nodejs-kafka-client-lib/src/raw/rdkafka_raw_consumer.ts @@ -279,7 +279,7 @@ export class MLKafkaRawConsumer extends EventEmitter implements IRawMessageConsu if (!this._client.isConnected() || this._consuming) return; const callContinue = ()=>{ - process.nextTick(() => { + setImmediate(() => { this._consumeLoop(); }); this._consuming = false;