Guard against interruption during calls to the consumer

zio · Nov 9, 2024 · 0423f31 · 0423f31
1 parent 1e74334
commit 0423f31
Showing 1 changed file with 1 addition 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
@@ -580,7 +580,7 @@ private[consumer] final class Runloop private (
                               )
                           }
           } yield pollresult
-        }
+        }.uninterruptible // Make sure that calls to the consumer are completed, so that its single-thread access protection locks are released
       fulfillResult <- offerRecordsToStreams(
                          pollResult.assignedStreams,
                          pollResult.pendingRequests,