Do not clear assignedStreams when ending streams by subscription (ins…

…ight from #1360)
zio · Nov 9, 2024 · 8e461ee · 8e461ee
1 parent ddbd576
commit 8e461ee
Showing 1 changed file with 1 addition and 3 deletions.
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
@@ -691,9 +691,7 @@ private[consumer] final class Runloop private (
           .as(
             state.copy(
               pendingRequests =
-                state.pendingRequests.filterNot(req => Subscription.subscriptionMatches(subscription, req.tp)),
-              assignedStreams =
-                state.assignedStreams.filterNot(stream => Subscription.subscriptionMatches(subscription, stream.tp))
+                state.pendingRequests.filterNot(req => Subscription.subscriptionMatches(subscription, req.tp))
             )
           )