From 29ff1c2d81cbed81e4e1edba122143fa3c23d3c4 Mon Sep 17 00:00:00 2001
From: Erik van Oosten <e.vanoosten@grons.nl>
Date: Wed, 4 Dec 2024 15:27:37 +0100
Subject: [PATCH] Run on top level executor

---
 .../src/main/scala/zio/kafka/consumer/internal/Runloop.scala   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala b/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala
index 8255d6836..6105432db 100644
--- a/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala
+++ b/zio-kafka/src/main/scala/zio/kafka/consumer/internal/Runloop.scala
@@ -150,7 +150,8 @@ private[consumer] final class Runloop private (
                    streamControl.offerRecords(builder.result())
                  }
                }
-               .fork
+              .fork
+              .onExecutor(topLevelExecutor)
       } yield fulfillResult
     }
   }