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