fd4s · bplommer · Jan 2, 2022 · Nov 22, 2021
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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)