diff --git a/modules/core/src/test/scala/fs2/kafka/internal/SyntaxSpec.scala b/modules/core/src/test/scala/fs2/kafka/internal/SyntaxSpec.scala
index 3f5e51fb6..731f87115 100644
--- a/modules/core/src/test/scala/fs2/kafka/internal/SyntaxSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/internal/SyntaxSpec.scala
@@ -6,7 +6,6 @@ import fs2.kafka._
 import fs2.kafka.BaseSpec
 import fs2.kafka.internal.syntax._
 import org.apache.kafka.common.KafkaFuture
-import org.apache.kafka.common.KafkaFuture.BiConsumer
 
 import java.time.temporal.ChronoUnit.MICROS
 import org.apache.kafka.common.header.internals.RecordHeaders