diff --git a/zio-kafka-test/src/test/scala/zio/kafka/consumer/fetch/ManyPartitionsQueueSizeBasedFetchStrategySpec.scala b/zio-kafka-test/src/test/scala/zio/kafka/consumer/fetch/ManyPartitionsQueueSizeBasedFetchStrategySpec.scala
index 55813da67..28b64287e 100644
--- a/zio-kafka-test/src/test/scala/zio/kafka/consumer/fetch/ManyPartitionsQueueSizeBasedFetchStrategySpec.scala
+++ b/zio-kafka-test/src/test/scala/zio/kafka/consumer/fetch/ManyPartitionsQueueSizeBasedFetchStrategySpec.scala
@@ -70,11 +70,11 @@ object ManyPartitionsQueueSizeBasedFetchStrategySpec extends ZIOSpecDefaultSlf4j
           result3 <- fetchStrategy.selectPartitionsToFetch(streams)
           result4 <- fetchStrategy.selectPartitionsToFetch(streams)
           result5 <- fetchStrategy.selectPartitionsToFetch(streams)
-          result = Chunk(result1, result2, result3, result4, result5)
+          results = Chunk(result1, result2, result3, result4, result5)
         } yield assertTrue(
-          result.forall(_.size == 2),
-          result.forall(_.forall(_.topic() == "topic2")),
-          result.flatten.toSet.size == 3
+          results.forall(_.size == 2),
+          results.forall(_.forall(_.topic() == "topic2")),
+          results.flatten.toSet.size == 3
         )
       }
     )