From 8e461eee0062f63ba725f57966ad37826b44d615 Mon Sep 17 00:00:00 2001 From: Steven Vroonland Date: Sat, 9 Nov 2024 11:12:41 +0100 Subject: [PATCH] Do not clear assignedStreams when ending streams by subscription (insight from #1360) --- .../src/main/scala/zio/kafka/consumer/internal/Runloop.scala | 4 +--- 1 file changed, 1 insertion(+), 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 index 1336167ad..fcd36d454 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 @@ -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)) ) )