From d3bc694bc62602768a63c50e7c3ceb6223fc8335 Mon Sep 17 00:00:00 2001
From: "a.artigao" <a.artigao@stuart.com>
Date: Fri, 17 Nov 2023 07:18:44 +0100
Subject: [PATCH] Fix flaky `KafkaConsumer#assignmentStream` tests

---
 modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala | 2 --
 1 file changed, 2 deletions(-)

diff --git a/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala b/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala
index ea27013a2..6fc34de7e 100644
--- a/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala
@@ -778,7 +778,6 @@ final class KafkaConsumerSpec extends BaseKafkaSpec {
                    .evalMap { consumer =>
                      consumer
                        .assignmentStream
-                       .concurrently(consumer.records)
                        .evalMap(as => queue.offer(Some(as)))
                        .compile
                        .drain
@@ -837,7 +836,6 @@ final class KafkaConsumerSpec extends BaseKafkaSpec {
                    .evalMap { consumer =>
                      consumer
                        .assignmentStream
-                       .concurrently(consumer.records)
                        .evalMap(as => queue.offer(Some(as)))
                        .compile
                        .drain