feat(nodejs-kafka-client-lib): Fixed consume continue call in MLKafka…

…RawConsumer
mojaloop · Apr 12, 2024 · d11fdb9 · d11fdb9
1 parent c4834ae
commit d11fdb9
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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;