From d11fdb965db7f95a0ec5f323951b4ce656cbddc4 Mon Sep 17 00:00:00 2001
From: Pedro Sousa Barreto <pedrosousabarreto@gmail.com>
Date: Fri, 12 Apr 2024 20:05:41 +0100
Subject: [PATCH] feat(nodejs-kafka-client-lib): Fixed consume continue call in
 MLKafkaRawConsumer

---
 .../nodejs-kafka-client-lib/src/raw/rdkafka_raw_consumer.ts     | 2 +-
 1 file changed, 1 insertion(+), 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
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;