diff --git a/.gitignore b/.gitignore
index 621f66236..f7f4fa41e 100644
--- a/.gitignore
+++ b/.gitignore
@@ -4,3 +4,5 @@
 /website/variables.js
 /website/yarn.lock
 target/
+.metals/
+.vscode/
diff --git a/docs/src/main/mdoc/admin.md b/docs/src/main/mdoc/admin.md
index c653a78c5..a3574d33e 100644
--- a/docs/src/main/mdoc/admin.md
+++ b/docs/src/main/mdoc/admin.md
@@ -10,7 +10,7 @@ The following imports are assumed throughout this page.
 
 ```scala mdoc:silent
 import cats.effect._
-import cats.implicits._
+import cats.syntax.all._
 import fs2.Stream
 import fs2.kafka._
 ```
diff --git a/docs/src/main/mdoc/consumers.md b/docs/src/main/mdoc/consumers.md
index 97e46c632..a131a167a 100644
--- a/docs/src/main/mdoc/consumers.md
+++ b/docs/src/main/mdoc/consumers.md
@@ -9,7 +9,7 @@ The following imports are assumed throughout this page.
 
 ```scala mdoc:silent
 import cats.effect._
-import cats.implicits._
+import cats.syntax.all._
 import fs2.kafka._
 import scala.concurrent.duration._
 ```
@@ -356,12 +356,12 @@ object WithGracefulShutdownExample extends IOApp {
     }
 
     def handleError(e: Throwable): IO[Unit] = IO(println(e.toString))
-    
+
     for {
       stoppedDeferred <- Deferred[IO, Either[Throwable, Unit]] // [1]
       gracefulShutdownStartedRef <- Ref[IO].of(false) // [2]
       _ <- KafkaConsumer.resource(consumerSettings)
-        .allocated.bracketCase { case (consumer, _) => // [3] 
+        .allocated.bracketCase { case (consumer, _) => // [3]
           run(consumer).attempt.flatMap { result: Either[Throwable, Unit] => // [4]
             gracefulShutdownStartedRef.get.flatMap {
               case true => stoppedDeferred.complete(result) // [5]
diff --git a/docs/src/main/mdoc/modules.md b/docs/src/main/mdoc/modules.md
index 6d4a8cf3d..81100aceb 100644
--- a/docs/src/main/mdoc/modules.md
+++ b/docs/src/main/mdoc/modules.md
@@ -19,7 +19,7 @@ resolvers += "confluent" at "https://packages.confluent.io/maven/",
 We start by defining the type we want to serialize or deserialize, and create a `Codec`.
 
 ```scala mdoc:reset-object
-import cats.implicits._
+import cats.syntax.all._
 import vulcan.Codec
 
 final case class Person(name: String, age: Option[Int])
diff --git a/docs/src/main/mdoc/producers.md b/docs/src/main/mdoc/producers.md
index a95299a2b..798cfe404 100644
--- a/docs/src/main/mdoc/producers.md
+++ b/docs/src/main/mdoc/producers.md
@@ -9,7 +9,7 @@ The following imports are assumed throughout this page.
 
 ```scala mdoc:silent
 import cats.effect._
-import cats.implicits._
+import cats.syntax.all._
 import fs2.kafka._
 import scala.concurrent.duration._
 ```
diff --git a/modules/core/src/main/scala/fs2/kafka/ConsumerRecord.scala b/modules/core/src/main/scala/fs2/kafka/ConsumerRecord.scala
index 0752b4f32..9c69003e2 100644
--- a/modules/core/src/main/scala/fs2/kafka/ConsumerRecord.scala
+++ b/modules/core/src/main/scala/fs2/kafka/ConsumerRecord.scala
@@ -6,7 +6,7 @@
 
 package fs2.kafka
 
-import cats.implicits._
+import cats.syntax.all._
 import cats.{Applicative, Apply, Bitraverse, Eq, Eval, Show, Traverse}
 import fs2.kafka.internal.syntax._
 import org.apache.kafka.clients.consumer.ConsumerRecord.{NO_TIMESTAMP, NULL_SIZE}
diff --git a/modules/core/src/main/scala/fs2/kafka/Deserializer.scala b/modules/core/src/main/scala/fs2/kafka/Deserializer.scala
index ccb8ead40..aef8bd258 100644
--- a/modules/core/src/main/scala/fs2/kafka/Deserializer.scala
+++ b/modules/core/src/main/scala/fs2/kafka/Deserializer.scala
@@ -8,7 +8,7 @@ package fs2.kafka
 
 import cats.MonadError
 import cats.effect.Sync
-import cats.implicits._
+import cats.syntax.all._
 import java.nio.charset.{Charset, StandardCharsets}
 import java.util.UUID
 
diff --git a/modules/core/src/main/scala/fs2/kafka/KafkaProducer.scala b/modules/core/src/main/scala/fs2/kafka/KafkaProducer.scala
index 35bb15736..cc61796e7 100644
--- a/modules/core/src/main/scala/fs2/kafka/KafkaProducer.scala
+++ b/modules/core/src/main/scala/fs2/kafka/KafkaProducer.scala
@@ -7,7 +7,7 @@
 package fs2.kafka
 
 import cats.effect._
-import cats.implicits._
+import cats.syntax.all._
 import cats.{Apply, Functor}
 import fs2.{Chunk, _}
 import fs2.kafka.internal._
diff --git a/modules/core/src/main/scala/fs2/kafka/KafkaProducerConnection.scala b/modules/core/src/main/scala/fs2/kafka/KafkaProducerConnection.scala
index 03f591f63..1ca6fbd63 100644
--- a/modules/core/src/main/scala/fs2/kafka/KafkaProducerConnection.scala
+++ b/modules/core/src/main/scala/fs2/kafka/KafkaProducerConnection.scala
@@ -7,7 +7,7 @@
 package fs2.kafka
 
 import cats.effect._
-import cats.implicits._
+import cats.syntax.all._
 import fs2.Stream
 import fs2.kafka.internal._
 import fs2.kafka.producer.MkProducer
diff --git a/modules/core/src/main/scala/fs2/kafka/Serializer.scala b/modules/core/src/main/scala/fs2/kafka/Serializer.scala
index 4ceedd729..aefda5165 100644
--- a/modules/core/src/main/scala/fs2/kafka/Serializer.scala
+++ b/modules/core/src/main/scala/fs2/kafka/Serializer.scala
@@ -8,7 +8,7 @@ package fs2.kafka
 
 import cats.Contravariant
 import cats.effect.Sync
-import cats.implicits._
+import cats.syntax.all._
 import java.nio.charset.{Charset, StandardCharsets}
 import java.util.UUID
 
diff --git a/modules/core/src/main/scala/fs2/kafka/internal/LogEntry.scala b/modules/core/src/main/scala/fs2/kafka/internal/LogEntry.scala
index 39b985a48..1e2e25b89 100644
--- a/modules/core/src/main/scala/fs2/kafka/internal/LogEntry.scala
+++ b/modules/core/src/main/scala/fs2/kafka/internal/LogEntry.scala
@@ -7,7 +7,7 @@
 package fs2.kafka.internal
 
 import cats.data.{Chain, NonEmptyList, NonEmptySet, NonEmptyVector}
-import cats.implicits._
+import cats.syntax.all._
 import fs2.Chunk
 import fs2.kafka.CommittableConsumerRecord
 import fs2.kafka.instances._
diff --git a/modules/core/src/main/scala/fs2/kafka/internal/Logging.scala b/modules/core/src/main/scala/fs2/kafka/internal/Logging.scala
index fefcbed5a..5645857c4 100644
--- a/modules/core/src/main/scala/fs2/kafka/internal/Logging.scala
+++ b/modules/core/src/main/scala/fs2/kafka/internal/Logging.scala
@@ -7,7 +7,7 @@
 package fs2.kafka.internal
 
 import cats.effect.Sync
-import cats.implicits._
+import cats.syntax.all._
 import org.slf4j.LoggerFactory
 
 private[kafka] sealed abstract class Logging[F[_]] {
diff --git a/modules/core/src/main/scala/fs2/kafka/internal/WithAdminClient.scala b/modules/core/src/main/scala/fs2/kafka/internal/WithAdminClient.scala
index c39040351..46a607e9a 100644
--- a/modules/core/src/main/scala/fs2/kafka/internal/WithAdminClient.scala
+++ b/modules/core/src/main/scala/fs2/kafka/internal/WithAdminClient.scala
@@ -7,7 +7,7 @@
 package fs2.kafka.internal
 
 import cats.effect.{Async, Resource, Sync}
-import cats.implicits._
+import cats.syntax.all._
 import fs2.kafka.AdminClientSettings
 import fs2.kafka.admin.MkAdminClient
 import fs2.kafka.internal.syntax._
diff --git a/modules/core/src/main/scala/fs2/kafka/internal/WithConsumer.scala b/modules/core/src/main/scala/fs2/kafka/internal/WithConsumer.scala
index 6a073d32f..a7c6fcfb5 100644
--- a/modules/core/src/main/scala/fs2/kafka/internal/WithConsumer.scala
+++ b/modules/core/src/main/scala/fs2/kafka/internal/WithConsumer.scala
@@ -7,7 +7,7 @@
 package fs2.kafka.internal
 
 import cats.effect.{Async, Resource}
-import cats.implicits._
+import cats.syntax.all._
 import fs2.kafka.consumer.MkConsumer
 import fs2.kafka.{ConsumerSettings, KafkaByteConsumer}
 import fs2.kafka.internal.syntax._
diff --git a/modules/core/src/main/scala/fs2/kafka/internal/WithProducer.scala b/modules/core/src/main/scala/fs2/kafka/internal/WithProducer.scala
index c0ee7aa64..ded13fe8e 100644
--- a/modules/core/src/main/scala/fs2/kafka/internal/WithProducer.scala
+++ b/modules/core/src/main/scala/fs2/kafka/internal/WithProducer.scala
@@ -8,7 +8,7 @@ package fs2.kafka.internal
 
 import fs2.kafka.producer.MkProducer
 import cats.effect.{Async, Resource}
-import cats.implicits._
+import cats.syntax.all._
 import fs2.kafka.{KafkaByteProducer, ProducerSettings, TransactionalProducerSettings}
 import fs2.kafka.internal.syntax._
 
diff --git a/modules/core/src/main/scala/fs2/kafka/internal/syntax.scala b/modules/core/src/main/scala/fs2/kafka/internal/syntax.scala
index 2bb8886c1..295fca5ba 100644
--- a/modules/core/src/main/scala/fs2/kafka/internal/syntax.scala
+++ b/modules/core/src/main/scala/fs2/kafka/internal/syntax.scala
@@ -9,7 +9,7 @@ package fs2.kafka.internal
 import cats.{FlatMap, Foldable, Show}
 import cats.effect.Async
 import cats.effect.syntax.all._
-import cats.implicits._
+import cats.syntax.all._
 import fs2.kafka.{Header, Headers, KafkaHeaders}
 import fs2.kafka.internal.converters.unsafeWrapArray
 import fs2.kafka.internal.converters.collection._
diff --git a/modules/core/src/test/scala/fs2/kafka/AdminClientSettingsSpec.scala b/modules/core/src/test/scala/fs2/kafka/AdminClientSettingsSpec.scala
index b35e950ed..1a5f35a0e 100644
--- a/modules/core/src/test/scala/fs2/kafka/AdminClientSettingsSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/AdminClientSettingsSpec.scala
@@ -1,6 +1,6 @@
 package fs2.kafka
 
-import cats.implicits._
+import cats.syntax.all._
 import org.apache.kafka.clients.admin.AdminClientConfig
 import scala.concurrent.duration._
 
diff --git a/modules/core/src/test/scala/fs2/kafka/BaseGenerators.scala b/modules/core/src/test/scala/fs2/kafka/BaseGenerators.scala
index 07fd4a5f9..e048d3e47 100644
--- a/modules/core/src/test/scala/fs2/kafka/BaseGenerators.scala
+++ b/modules/core/src/test/scala/fs2/kafka/BaseGenerators.scala
@@ -2,7 +2,7 @@ package fs2.kafka
 
 import cats.{ApplicativeError, ApplicativeThrow}
 import cats.effect._
-import cats.implicits._
+import cats.syntax.all._
 import org.apache.kafka.clients.consumer.OffsetAndMetadata
 import org.apache.kafka.common.TopicPartition
 import org.scalacheck.Arbitrary.arbitrary
diff --git a/modules/core/src/test/scala/fs2/kafka/CommittableConsumerRecordSpec.scala b/modules/core/src/test/scala/fs2/kafka/CommittableConsumerRecordSpec.scala
index 58d065332..ac19b0f36 100644
--- a/modules/core/src/test/scala/fs2/kafka/CommittableConsumerRecordSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/CommittableConsumerRecordSpec.scala
@@ -1,7 +1,7 @@
 package fs2.kafka
 
 import cats.effect.IO
-import cats.implicits._
+import cats.syntax.all._
 import org.apache.kafka.clients.consumer.OffsetAndMetadata
 import org.apache.kafka.common.TopicPartition
 
diff --git a/modules/core/src/test/scala/fs2/kafka/CommittableOffsetBatchSpec.scala b/modules/core/src/test/scala/fs2/kafka/CommittableOffsetBatchSpec.scala
index 0df125f25..f9efccaa2 100644
--- a/modules/core/src/test/scala/fs2/kafka/CommittableOffsetBatchSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/CommittableOffsetBatchSpec.scala
@@ -1,7 +1,7 @@
 package fs2.kafka
 
 import cats.effect.IO
-import cats.implicits._
+import cats.syntax.all._
 import org.apache.kafka.clients.consumer.OffsetAndMetadata
 import org.apache.kafka.common.TopicPartition
 import org.scalacheck.Gen
diff --git a/modules/core/src/test/scala/fs2/kafka/CommittableOffsetSpec.scala b/modules/core/src/test/scala/fs2/kafka/CommittableOffsetSpec.scala
index 81283579c..fa87db323 100644
--- a/modules/core/src/test/scala/fs2/kafka/CommittableOffsetSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/CommittableOffsetSpec.scala
@@ -2,7 +2,7 @@ package fs2.kafka
 
 import cats.effect.IO
 import cats.effect.unsafe.implicits.global
-import cats.implicits._
+import cats.syntax.all._
 import org.apache.kafka.clients.consumer.OffsetAndMetadata
 import org.apache.kafka.common.TopicPartition
 
diff --git a/modules/core/src/test/scala/fs2/kafka/ConsumerRecordSpec.scala b/modules/core/src/test/scala/fs2/kafka/ConsumerRecordSpec.scala
index e60a0d46d..bfa41cd9a 100644
--- a/modules/core/src/test/scala/fs2/kafka/ConsumerRecordSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/ConsumerRecordSpec.scala
@@ -2,7 +2,7 @@ package fs2.kafka
 
 import cats.effect.IO
 import cats.effect.unsafe.implicits.global
-import cats.implicits._
+import cats.syntax.all._
 import org.apache.kafka.clients.consumer.ConsumerRecord.{NULL_SIZE, NO_TIMESTAMP}
 import org.apache.kafka.common.record.TimestampType
 import org.apache.kafka.common.record.TimestampType._
diff --git a/modules/core/src/test/scala/fs2/kafka/ConsumerSettingsSpec.scala b/modules/core/src/test/scala/fs2/kafka/ConsumerSettingsSpec.scala
index 8079cd34a..cb5e96107 100644
--- a/modules/core/src/test/scala/fs2/kafka/ConsumerSettingsSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/ConsumerSettingsSpec.scala
@@ -2,7 +2,7 @@ package fs2.kafka
 
 import cats.effect.IO
 import cats.effect.unsafe.implicits.global
-import cats.implicits._
+import cats.syntax.all._
 import org.apache.kafka.clients.consumer.ConsumerConfig
 
 import scala.concurrent.ExecutionContext
diff --git a/modules/core/src/test/scala/fs2/kafka/KafkaAdminClientSpec.scala b/modules/core/src/test/scala/fs2/kafka/KafkaAdminClientSpec.scala
index 2ac3cfb02..4e5ccf06c 100644
--- a/modules/core/src/test/scala/fs2/kafka/KafkaAdminClientSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/KafkaAdminClientSpec.scala
@@ -1,7 +1,7 @@
 package fs2.kafka
 
 import cats.effect.{IO, SyncIO}
-import cats.implicits._
+import cats.syntax.all._
 import cats.effect.unsafe.implicits.global
 import org.apache.kafka.clients.admin.{AlterConfigOp, ConfigEntry, NewPartitions, NewTopic}
 import org.apache.kafka.clients.consumer.OffsetAndMetadata
diff --git a/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala b/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala
index 3af3e06a4..83dfd026f 100644
--- a/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/KafkaConsumerSpec.scala
@@ -4,7 +4,7 @@ import cats.data.NonEmptySet
 import cats.effect.Ref
 import cats.effect.{Fiber, IO}
 import cats.effect.std.Queue
-import cats.implicits._
+import cats.syntax.all._
 import cats.effect.unsafe.implicits.global
 import fs2.Stream
 import fs2.concurrent.SignallingRef
diff --git a/modules/core/src/test/scala/fs2/kafka/KafkaProducerSpec.scala b/modules/core/src/test/scala/fs2/kafka/KafkaProducerSpec.scala
index 77f372c94..6507a61d1 100644
--- a/modules/core/src/test/scala/fs2/kafka/KafkaProducerSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/KafkaProducerSpec.scala
@@ -2,7 +2,7 @@ package fs2.kafka
 
 import cats.effect.IO
 import cats.effect.unsafe.implicits.global
-import cats.implicits._
+import cats.syntax.all._
 import fs2.{Chunk, Stream}
 
 final class KafkaProducerSpec extends BaseKafkaSpec {
diff --git a/modules/core/src/test/scala/fs2/kafka/ProducerRecordsSpec.scala b/modules/core/src/test/scala/fs2/kafka/ProducerRecordsSpec.scala
index 4ca23f028..74d102aae 100644
--- a/modules/core/src/test/scala/fs2/kafka/ProducerRecordsSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/ProducerRecordsSpec.scala
@@ -1,6 +1,6 @@
 package fs2.kafka
 
-import cats.implicits._
+import cats.syntax.all._
 
 final class ProducerRecordsSpec extends BaseSpec {
   describe("ProducerRecords") {
diff --git a/modules/core/src/test/scala/fs2/kafka/ProducerResultSpec.scala b/modules/core/src/test/scala/fs2/kafka/ProducerResultSpec.scala
index 46566080a..36e9f67c1 100644
--- a/modules/core/src/test/scala/fs2/kafka/ProducerResultSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/ProducerResultSpec.scala
@@ -1,7 +1,7 @@
 package fs2.kafka
 
 import fs2.Chunk
-import cats.implicits._
+import cats.syntax.all._
 import org.apache.kafka.clients.producer.RecordMetadata
 import org.apache.kafka.common.TopicPartition
 
diff --git a/modules/core/src/test/scala/fs2/kafka/ProducerSettingsSpec.scala b/modules/core/src/test/scala/fs2/kafka/ProducerSettingsSpec.scala
index 9c25a2d5d..2eca0e1c3 100644
--- a/modules/core/src/test/scala/fs2/kafka/ProducerSettingsSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/ProducerSettingsSpec.scala
@@ -2,7 +2,7 @@ package fs2.kafka
 
 import cats.effect.IO
 import cats.effect.unsafe.implicits.global
-import cats.implicits._
+import cats.syntax.all._
 import org.apache.kafka.clients.producer.ProducerConfig
 
 import scala.concurrent.ExecutionContext
diff --git a/modules/core/src/test/scala/fs2/kafka/TransactionalKafkaProducerSpec.scala b/modules/core/src/test/scala/fs2/kafka/TransactionalKafkaProducerSpec.scala
index 50d21a8a3..65b1cb33c 100644
--- a/modules/core/src/test/scala/fs2/kafka/TransactionalKafkaProducerSpec.scala
+++ b/modules/core/src/test/scala/fs2/kafka/TransactionalKafkaProducerSpec.scala
@@ -4,7 +4,7 @@ import java.util
 import cats.data.NonEmptyList
 import cats.effect.IO
 import cats.effect.unsafe.implicits.global
-import cats.implicits._
+import cats.syntax.all._
 import fs2.{Chunk, Stream}
 import fs2.kafka.internal.converters.collection._
 import fs2.kafka.producer.MkProducer
diff --git a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroDeserializer.scala b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroDeserializer.scala
index 286950035..70260e53f 100644
--- a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroDeserializer.scala
+++ b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroDeserializer.scala
@@ -8,7 +8,7 @@ package fs2.kafka.vulcan
 
 import _root_.vulcan.Codec
 import cats.effect.Sync
-import cats.implicits._
+import cats.syntax.all._
 import fs2.kafka.{Deserializer, RecordDeserializer}
 import io.confluent.kafka.schemaregistry.avro.AvroSchema
 import java.nio.ByteBuffer
diff --git a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSerializer.scala b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSerializer.scala
index a42440341..06e6eb74b 100644
--- a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSerializer.scala
+++ b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSerializer.scala
@@ -8,7 +8,7 @@ package fs2.kafka.vulcan
 
 import _root_.vulcan.Codec
 import cats.effect.Sync
-import cats.implicits._
+import cats.syntax.all._
 import fs2.kafka.{RecordSerializer, Serializer}
 
 final class AvroSerializer[A] private[vulcan] (
diff --git a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala
index 59a2bde0f..173dcdedd 100644
--- a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala
+++ b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala
@@ -7,7 +7,7 @@
 package fs2.kafka.vulcan
 
 import cats.effect.Sync
-import cats.implicits._
+import cats.syntax.all._
 import fs2.kafka.internal.converters.collection._
 import fs2.kafka.internal.syntax._
 
diff --git a/modules/vulcan/src/test/scala/fs2/kafka/vulcan/PackageSpec.scala b/modules/vulcan/src/test/scala/fs2/kafka/vulcan/PackageSpec.scala
index 24b0386e8..a790a18d6 100644
--- a/modules/vulcan/src/test/scala/fs2/kafka/vulcan/PackageSpec.scala
+++ b/modules/vulcan/src/test/scala/fs2/kafka/vulcan/PackageSpec.scala
@@ -2,7 +2,7 @@ package fs2.kafka.vulcan
 
 import java.time.Instant
 
-import cats.implicits._
+import cats.syntax.all._
 import cats.effect.IO
 import cats.effect.unsafe.implicits.global
 import fs2.kafka._
diff --git a/modules/vulcan/src/test/scala/fs2/kafka/vulcan/SchemaRegistryClientSettingsSpec.scala b/modules/vulcan/src/test/scala/fs2/kafka/vulcan/SchemaRegistryClientSettingsSpec.scala
index b8a59e5ea..e9ed8a34b 100644
--- a/modules/vulcan/src/test/scala/fs2/kafka/vulcan/SchemaRegistryClientSettingsSpec.scala
+++ b/modules/vulcan/src/test/scala/fs2/kafka/vulcan/SchemaRegistryClientSettingsSpec.scala
@@ -2,7 +2,7 @@ package fs2.kafka.vulcan
 
 import cats.effect.IO
 import cats.effect.unsafe.implicits.global
-import cats.implicits._
+import cats.syntax.all._
 import org.scalatest.funspec.AnyFunSpec
 import org.scalatestplus.scalacheck._
 
diff --git a/scalafix/input/src/main/scala/fix/PassthroughParams.scala b/scalafix/input/src/main/scala/fix/PassthroughParams.scala
index 655977707..250531d06 100644
--- a/scalafix/input/src/main/scala/fix/PassthroughParams.scala
+++ b/scalafix/input/src/main/scala/fix/PassthroughParams.scala
@@ -5,7 +5,7 @@ rule = Fs2Kafka
 package fix
 
 import fs2.kafka._
-import cats.implicits._
+import cats.syntax.all._
 import fs2.Chunk
 import cats.effect.IO
 
@@ -35,7 +35,7 @@ class PassthroughParams {
   val result: ProducerResult[String, String, Int] =
     ProducerResult[String, String, Int](Chunk.empty, 42)
 
-  val tRecords: TransactionalProducerRecords[IO, String, String, Int] = 
+  val tRecords: TransactionalProducerRecords[IO, String, String, Int] =
     TransactionalProducerRecords[IO, String, String, Int](Chunk.empty, 42)
 
   TransactionalProducerRecords.one[IO, String, String, Int](???, 42)
diff --git a/scalafix/output/src/main/scala/fix/PassthroughParams.scala b/scalafix/output/src/main/scala/fix/PassthroughParams.scala
index 0264ba0a0..a38433ebe 100644
--- a/scalafix/output/src/main/scala/fix/PassthroughParams.scala
+++ b/scalafix/output/src/main/scala/fix/PassthroughParams.scala
@@ -1,7 +1,7 @@
 package fix
 
 import fs2.kafka._
-import cats.implicits._
+import cats.syntax.all._
 import fs2.Chunk
 import cats.effect.IO
 
@@ -31,7 +31,7 @@ class PassthroughParams {
   val result: ProducerResult[Int, String, String] =
     ProducerResult[Int, String, String](Chunk.empty, 42)
 
-  val tRecords: TransactionalProducerRecords[IO, Int, String, String] = 
+  val tRecords: TransactionalProducerRecords[IO, Int, String, String] =
     TransactionalProducerRecords[IO, Int, String, String](Chunk.empty, 42)
 
   TransactionalProducerRecords.one[IO, Int, String, String](???, 42)