Run on top level executor

zio · Dec 4, 2024 · 29ff1c2 · 29ff1c2
1 parent c39b18a
commit 29ff1c2
Showing 1 changed file with 2 additions and 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
@@ -150,7 +150,8 @@ private[consumer] final class Runloop private (
                    streamControl.offerRecords(builder.result())
                  }
                }
-               .fork
+              .fork
+              .onExecutor(topLevelExecutor)
       } yield fulfillResult
     }
   }