From 1485d1d613ad1dfe979ea843215db5246d232bf8 Mon Sep 17 00:00:00 2001 From: Steven Vroonland Date: Sat, 9 Nov 2024 15:32:37 +0100 Subject: [PATCH] Remove thing that will not fix anything --- .../src/main/scala/zio/kafka/consumer/internal/Runloop.scala | 2 +- 1 file changed, 1 insertion(+), 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 5fd49187f..d01949d8f 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 @@ -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,