Merge pull request #712 from scala-steward/update/alleycats-core-2.2.0

Update alleycats-core, cats-core, cats-free, ... to 2.2.0
chenharryhua · Sep 3, 2020 · 934ddd4 · 934ddd4
2 parents fc88ccd + 76a52ed
commit 934ddd4
Show file tree

Hide file tree

Showing 83 changed files with 58 additions and 93 deletions.
diff --git a/build.sbt b/build.sbt
@@ -9,7 +9,7 @@ version in ThisBuild := "0.8.0-SNAPSHOT"
 val shapeless  = "2.3.3"
 val contextual = "1.2.1"
 val kittens    = "2.1.0"
-val catsCore   = "2.2.0-RC4"
+val catsCore   = "2.2.0"
 val algebra    = "2.0.1"
 val fs2Version = "2.4.4"
 val streamz    = "0.13-RC1"

diff --git a/common/src/main/scala/com/github/chenharryhua/nanjin/common/NJFileFormat.scala b/common/src/main/scala/com/github/chenharryhua/nanjin/common/NJFileFormat.scala
@@ -1,6 +1,4 @@
 package com.github.chenharryhua.nanjin.common
-
-import cats.instances.int._
 import enumeratum.values.{CatsOrderValueEnum, IntEnum, IntEnumEntry}
 import monocle.Prism
 import monocle.generic.coproduct.coProductPrism

diff --git a/common/src/main/scala/com/github/chenharryhua/nanjin/utils/Keyboard.scala b/common/src/main/scala/com/github/chenharryhua/nanjin/utils/Keyboard.scala
@@ -4,7 +4,7 @@ import cats.effect.{Concurrent, Sync}
 import fs2.Stream
 import fs2.concurrent.Signal
 import org.jline.terminal.{Terminal, TerminalBuilder}
-import cats.implicits._
+import cats.syntax.all._
 
 object Keyboard {
   val pauSe: Char    = 's'

diff --git a/database/src/main/scala/com/github/chenharryhua/nanjin/database/DatabaseSettings.scala b/database/src/main/scala/com/github/chenharryhua/nanjin/database/DatabaseSettings.scala
@@ -1,7 +1,7 @@
 package com.github.chenharryhua.nanjin.database
 
 import cats.effect.{Async, Blocker, Concurrent, ContextShift, Resource, Timer}
-import cats.implicits._
+import cats.syntax.all._
 import doobie.free.connection.{AsyncConnectionIO, ConnectionIO}
 import doobie.hikari.HikariTransactor
 import doobie.util.ExecutionContexts

diff --git a/datetime/src/main/scala/com/github/chenharryhua/nanjin/datetime/DateTimeParser.scala b/datetime/src/main/scala/com/github/chenharryhua/nanjin/datetime/DateTimeParser.scala
@@ -5,7 +5,7 @@ import java.time.format.DateTimeParseException
 
 import cats.Alternative
 import cats.data.NonEmptyList
-import cats.implicits._
+import cats.syntax.all._
 
 final case class FailedParsers(parsers: NonEmptyList[String]) extends AnyVal {
   def concat(other: FailedParsers): FailedParsers = FailedParsers(parsers ::: other.parsers)

diff --git a/datetime/src/main/scala/com/github/chenharryhua/nanjin/datetime/NJDateTimeRange.scala b/datetime/src/main/scala/com/github/chenharryhua/nanjin/datetime/NJDateTimeRange.scala
@@ -2,8 +2,6 @@ package com.github.chenharryhua.nanjin.datetime
 
 import java.sql.Timestamp
 import java.time._
-
-import cats.implicits._
 import cats.{PartialOrder, Show}
 import monocle.Prism
 import monocle.generic.coproduct.coProductPrism

diff --git a/datetime/src/main/scala/com/github/chenharryhua/nanjin/datetime/NJTimestamp.scala b/datetime/src/main/scala/com/github/chenharryhua/nanjin/datetime/NJTimestamp.scala
@@ -5,7 +5,7 @@ import java.time._
 import java.time.temporal.{ChronoUnit, TemporalUnit}
 import java.util.concurrent.TimeUnit
 
-import cats.implicits._
+import cats.syntax.all._
 import cats.{Hash, Order, Show}
 
 import scala.concurrent.duration.{Duration, FiniteDuration}

diff --git a/datetime/src/test/scala/mtest/DateTimeRangeTest.scala b/datetime/src/test/scala/mtest/DateTimeRangeTest.scala
@@ -9,7 +9,7 @@ import org.scalacheck.{Arbitrary, Cogen, Gen}
 import org.scalatest.funsuite.AnyFunSuite
 import org.scalatest.prop.Configuration
 import org.typelevel.discipline.scalatest.FunSuiteDiscipline
-import cats.implicits._
+import cats.syntax.all._
 
 class DateTimeRangeTest extends AnyFunSuite with FunSuiteDiscipline with Configuration {
 

diff --git a/devices/src/main/scala/com/github/chenharryhua/nanjin/devices/FtpDownloader.scala b/devices/src/main/scala/com/github/chenharryhua/nanjin/devices/FtpDownloader.scala
@@ -4,7 +4,7 @@ import akka.stream.Materializer
 import akka.stream.alpakka.ftp.scaladsl.{Ftp, FtpApi, Ftps, Sftp}
 import akka.stream.alpakka.ftp.{FtpSettings, FtpsSettings, RemoteFileSettings, SftpSettings}
 import cats.effect.{Async, Concurrent, ContextShift}
-import cats.implicits._
+import cats.syntax.all._
 import fs2.{Chunk, Stream}
 import net.schmizz.sshj.SSHClient
 import org.apache.commons.net.ftp.{FTPClient, FTPSClient}

diff --git a/devices/src/main/scala/com/github/chenharryhua/nanjin/devices/NJHadoop.scala b/devices/src/main/scala/com/github/chenharryhua/nanjin/devices/NJHadoop.scala
@@ -4,7 +4,7 @@ import java.io.InputStream
 import java.net.URI
 
 import cats.effect.{Blocker, ContextShift, Resource, Sync}
-import cats.implicits._
+import cats.syntax.all._
 import fs2.io.{readInputStream, writeOutputStream}
 import fs2.{Pipe, Pull, Stream}
 import org.apache.avro.Schema

diff --git a/devices/src/test/scala/mtest/FtpTest.scala b/devices/src/test/scala/mtest/FtpTest.scala
@@ -1,7 +1,7 @@
 package mtest
 
 import cats.effect.IO
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.devices.{AkkaFtpDownloader, AkkaFtpUploader}
 import fs2.Stream
 import org.scalatest.Ignore

diff --git a/devices/src/test/scala/mtest/HadoopTest.scala b/devices/src/test/scala/mtest/HadoopTest.scala
@@ -1,7 +1,7 @@
 package mtest
 
 import cats.effect.IO
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.devices.NJHadoop
 import fs2.Stream
 import fs2.io.readInputStream

diff --git a/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaAdminApi.scala b/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaAdminApi.scala
@@ -1,7 +1,7 @@
 package com.github.chenharryhua.nanjin.kafka
 
 import cats.effect.{Concurrent, ContextShift, Resource}
-import cats.implicits._
+import cats.syntax.all._
 import fs2.kafka.{adminClientResource, AdminClientSettings, KafkaAdminClient}
 import org.apache.kafka.clients.admin.{NewTopic, TopicDescription}
 

diff --git a/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaChannels.scala b/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaChannels.scala
@@ -8,7 +8,7 @@ import akka.kafka.{
 import akka.stream.Materializer
 import cats.data.{NonEmptyList, Reader}
 import cats.effect._
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.datetime.NJDateTimeRange
 import com.github.chenharryhua.nanjin.utils
 import fs2.Stream

diff --git a/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaDomainObjects.scala b/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaDomainObjects.scala
@@ -2,7 +2,7 @@ package com.github.chenharryhua.nanjin.kafka
 
 import java.{lang, util}
 
-import cats.implicits._
+import cats.syntax.all._
 import cats.{Order, PartialOrder, Show}
 import com.github.chenharryhua.nanjin.datetime.NJTimestamp
 import eu.timepit.refined.api.Refined

diff --git a/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaMonitoringApi.scala b/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaMonitoringApi.scala
@@ -3,7 +3,7 @@ package com.github.chenharryhua.nanjin.kafka
 import java.time.ZoneId
 
 import cats.effect.{Blocker, ConcurrentEffect, ContextShift, Timer}
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.datetime.NJTimestamp
 import com.github.chenharryhua.nanjin.messages.kafka.NJConsumerMessage._
 import com.github.chenharryhua.nanjin.messages.kafka._

diff --git a/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaStreamRunner.scala b/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaStreamRunner.scala
@@ -3,7 +3,7 @@ package com.github.chenharryhua.nanjin.kafka
 import cats.data.Reader
 import cats.effect.ConcurrentEffect
 import cats.effect.concurrent.Deferred
-import cats.implicits._
+import cats.syntax.all._
 import fs2.Stream
 import org.apache.kafka.streams.KafkaStreams
 import org.apache.kafka.streams.scala.StreamsBuilder

diff --git a/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaTopic.scala b/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaTopic.scala
@@ -1,7 +1,7 @@
 package com.github.chenharryhua.nanjin.kafka
 
 import cats.effect.{Concurrent, ConcurrentEffect, ContextShift, Resource, Sync, Timer}
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.messages.kafka.NJConsumerMessage
 import com.github.chenharryhua.nanjin.messages.kafka.codec.{
   KafkaGenericDecoder,

diff --git a/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaTopicCodec.scala b/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaTopicCodec.scala
@@ -1,6 +1,6 @@
 package com.github.chenharryhua.nanjin.kafka
 
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.messages.kafka.codec.{NJCodec, SerdeOf}
 import com.sksamuel.avro4s.SchemaFor
 import org.apache.kafka.common.serialization.{Deserializer, Serializer}

diff --git a/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaTopicProducer.scala b/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/KafkaTopicProducer.scala
@@ -4,7 +4,7 @@ import akka.NotUsed
 import akka.kafka.ProducerMessage
 import cats.Traverse
 import cats.effect.{ConcurrentEffect, ContextShift, Resource}
-import cats.implicits._
+import cats.syntax.all._
 import fs2.kafka.{
   producerResource,
   KafkaProducer   => Fs2KafkaProducer,

diff --git a/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/SchemaRegistryApi.scala b/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/SchemaRegistryApi.scala
@@ -2,7 +2,7 @@ package com.github.chenharryhua.nanjin.kafka
 
 import cats.Show
 import cats.effect.{Resource, Sync}
-import cats.implicits._
+import cats.syntax.all._
 import io.confluent.kafka.schemaregistry.avro.AvroSchema
 import io.confluent.kafka.schemaregistry.client.{CachedSchemaRegistryClient, SchemaMetadata}
 import io.confluent.kafka.serializers.AbstractKafkaSchemaSerDeConfig

diff --git a/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/ShowKafkaMessage.scala b/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/ShowKafkaMessage.scala
@@ -4,7 +4,7 @@ import java.time.ZoneId
 
 import akka.kafka.ConsumerMessage.CommittableMessage
 import cats.Show
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.datetime.NJTimestamp
 import com.github.chenharryhua.nanjin.messages.kafka._
 import com.sksamuel.avro4s.Record

diff --git a/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/TopicDef.scala b/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/TopicDef.scala
@@ -1,6 +1,6 @@
 package com.github.chenharryhua.nanjin.kafka
 
-import cats.implicits._
+import cats.syntax.all._
 import cats.kernel.Eq
 import com.github.chenharryhua.nanjin.messages.kafka._
 import com.github.chenharryhua.nanjin.messages.kafka.codec.{NJAvroCodec, SerdeOf}

diff --git a/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/akkaSinks.scala b/kafka/src/main/scala/com/github/chenharryhua/nanjin/kafka/akkaSinks.scala
@@ -6,7 +6,7 @@ import akka.stream.stage.{GraphStageLogic, GraphStageWithMaterializedValue, InHa
 import akka.stream.{Attributes, Inlet, SinkShape}
 import cats.effect.ConcurrentEffect
 import cats.effect.concurrent.Deferred
-import cats.implicits._
+import cats.syntax.all._
 
 object akkaSinks {
 

diff --git a/kafka/src/test/scala/mtest/kafka/CompilationTest.scala b/kafka/src/test/scala/mtest/kafka/CompilationTest.scala
@@ -4,7 +4,7 @@ import akka.kafka.ConsumerMessage
 import akka.kafka.scaladsl.Consumer
 import akka.stream.scaladsl.Source
 import org.scalatest.funsuite.AnyFunSuite
-import cats.implicits._
+import cats.syntax.all._
 
 import scala.util.Try
 import cats.effect.IO

diff --git a/kafka/src/test/scala/mtest/kafka/ConsumeMessageAkkaTest.scala b/kafka/src/test/scala/mtest/kafka/ConsumeMessageAkkaTest.scala
@@ -3,7 +3,7 @@ package mtest.kafka
 import java.time.LocalDateTime
 
 import cats.derived.auto.show._
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.kafka.{KafkaOffset, TopicName, _}
 import org.scalatest.funsuite.AnyFunSuite
 import cats.effect.IO

diff --git a/kafka/src/test/scala/mtest/kafka/ConsumeMessageFs2Test.scala b/kafka/src/test/scala/mtest/kafka/ConsumeMessageFs2Test.scala
@@ -1,7 +1,7 @@
 package mtest.kafka
 
 import cats.derived.auto.show._
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.kafka.{TopicName, _}
 import com.github.chenharryhua.nanjin.messages.kafka.codec.{KJson, NJAvroCodec}
 import com.landoop.telecom.telecomitalia.telecommunications.{smsCallInternet, Key}

diff --git a/kafka/src/test/scala/mtest/kafka/ConsumerApiOffsetRangeTest.scala b/kafka/src/test/scala/mtest/kafka/ConsumerApiOffsetRangeTest.scala
@@ -1,7 +1,7 @@
 package mtest.kafka
 
 import cats.effect.IO
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.datetime.{darwinTime, NJDateTimeRange}
 import com.github.chenharryhua.nanjin.kafka.{
   KafkaOffset,

diff --git a/kafka/src/test/scala/mtest/kafka/Domain.scala b/kafka/src/test/scala/mtest/kafka/Domain.scala
@@ -1,7 +1,6 @@
 package mtest.kafka
 
-import cats.Show
-import cats.implicits._  
+import cats.Show  
 
 case class Payment(
   id: String,

diff --git a/kafka/src/test/scala/mtest/kafka/KafkaStreamingTest.scala b/kafka/src/test/scala/mtest/kafka/KafkaStreamingTest.scala
@@ -1,7 +1,7 @@
 package mtest.kafka
 
 import cats.effect.IO
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.kafka.{KafkaTopic, TopicDef, TopicName}
 import com.github.chenharryhua.nanjin.messages.kafka.codec.{NJSerdeConfig, SerdeOf}
 import org.apache.kafka.common.serialization.Serde

diff --git a/kafka/src/test/scala/mtest/kafka/ProducerTest.scala b/kafka/src/test/scala/mtest/kafka/ProducerTest.scala
@@ -2,7 +2,7 @@ package mtest.kafka
 
 import akka.Done
 import cats.effect.IO
-import cats.implicits._
+import cats.syntax.all._
 import org.apache.kafka.clients.consumer.ConsumerConfig
 import org.scalatest.funsuite.AnyFunSuite
 import fs2.kafka.{ProducerRecords => Fs2ProducerRecords, ProducerRecord => Fs2ProducerRecord}

diff --git a/kafka/src/test/scala/mtest/kafka/ProtobufTest.scala b/kafka/src/test/scala/mtest/kafka/ProtobufTest.scala
@@ -1,7 +1,7 @@
 package mtest.kafka
 
 import cats.effect.IO
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.kafka.KafkaTopic
 import com.github.chenharryhua.nanjin.messages.kafka.codec.KPB
 import mtest.pb.test._

diff --git a/kafka/src/test/scala/mtest/kafka/ZioTest.scala b/kafka/src/test/scala/mtest/kafka/ZioTest.scala
@@ -1,7 +1,7 @@
 package mtest.kafka
 
 import cats.derived.auto.show._
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.kafka._
 import org.scalatest.Ignore
 import org.scalatest.funsuite.AnyFunSuite

diff --git a/kafka/src/test/scala/mtest/kafka/package.scala b/kafka/src/test/scala/mtest/kafka/package.scala
@@ -1,7 +1,6 @@
 package mtest
 
 import cats.effect.{Blocker, ContextShift, IO, Timer}
-import cats.implicits._
 import com.github.chenharryhua.nanjin.kafka.{IoKafkaContext, KafkaSettings, KafkaTopic}
 import org.apache.kafka.clients.consumer.ConsumerConfig
 

diff --git a/...ages/src/main/scala/com/github/chenharryhua/nanjin/messages/kafka/BitraverseMessage.scala b/...ages/src/main/scala/com/github/chenharryhua/nanjin/messages/kafka/BitraverseMessage.scala
@@ -5,7 +5,7 @@ import akka.kafka.ConsumerMessage.{
   TransactionalMessage => AkkaTransactionalMessage
 }
 import akka.kafka.ProducerMessage.{Message => AkkaProducerMessage}
-import cats.implicits._
+import cats.syntax.all._
 import cats.{Applicative, Bitraverse, Eval}
 import fs2.kafka.{
   CommittableConsumerRecord => Fs2CommittableConsumerRecord,

diff --git a/...ges/src/main/scala/com/github/chenharryhua/nanjin/messages/kafka/BitraverseMessages.scala b/...ges/src/main/scala/com/github/chenharryhua/nanjin/messages/kafka/BitraverseMessages.scala
@@ -1,7 +1,7 @@
 package com.github.chenharryhua.nanjin.messages.kafka
 
 import akka.kafka.ProducerMessage.{MultiMessage => AkkaMultiMessage}
-import cats.implicits._
+import cats.syntax.all._
 import cats.{Applicative, Bitraverse, Eval}
 import fs2.Chunk
 import fs2.kafka.{

diff --git a/messages/src/main/scala/com/github/chenharryhua/nanjin/messages/kafka/EqMessage.scala b/messages/src/main/scala/com/github/chenharryhua/nanjin/messages/kafka/EqMessage.scala
@@ -11,7 +11,7 @@ import akka.kafka.ConsumerMessage.{
 }
 import akka.kafka.ProducerMessage.{Message => AkkaProducerMessage, MultiMessage => AkkaMultiMessage}
 import cats.Eq
-import cats.implicits._
+import cats.syntax.all._
 import fs2.kafka.{
   CommittableConsumerRecord => Fs2CommittableConsumerRecord,
   CommittableOffset => Fs2CommittableOffset,

diff --git a/messages/src/main/scala/com/github/chenharryhua/nanjin/messages/kafka/NJConsumerRecord.scala b/messages/src/main/scala/com/github/chenharryhua/nanjin/messages/kafka/NJConsumerRecord.scala
@@ -3,7 +3,6 @@ package com.github.chenharryhua.nanjin.messages.kafka
 import java.time.Instant
 
 import alleycats.Empty
-import cats.implicits._
 import cats.kernel.{LowerBounded, PartialOrder}
 import cats.{Applicative, Bifunctor, Bitraverse, Eval, Order, Show}
 import com.sksamuel.avro4s.AvroDoc

diff --git a/messages/src/main/scala/com/github/chenharryhua/nanjin/messages/kafka/NJProducerRecord.scala b/messages/src/main/scala/com/github/chenharryhua/nanjin/messages/kafka/NJProducerRecord.scala
@@ -1,7 +1,6 @@
 package com.github.chenharryhua.nanjin.messages.kafka
 
 import alleycats.Empty
-import cats.implicits._
 import cats.{Bifunctor, Show}
 import fs2.kafka.{ProducerRecord => Fs2ProducerRecord}
 import io.circe.generic.semiauto.{deriveDecoder, deriveEncoder}

diff --git a/.../main/scala/com/github/chenharryhua/nanjin/messages/kafka/codec/KafkaGenericDecoder.scala b/.../main/scala/com/github/chenharryhua/nanjin/messages/kafka/codec/KafkaGenericDecoder.scala
@@ -1,6 +1,6 @@
 package com.github.chenharryhua.nanjin.messages.kafka.codec
 
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.messages.kafka._
 
 import scala.util.{Success, Try}

diff --git a/...ages/src/main/scala/com/github/chenharryhua/nanjin/messages/kafka/codec/NJAvroCodec.scala b/...ages/src/main/scala/com/github/chenharryhua/nanjin/messages/kafka/codec/NJAvroCodec.scala
@@ -1,7 +1,7 @@
 package com.github.chenharryhua.nanjin.messages.kafka.codec
 
 import cats.data.Ior
-import cats.implicits._
+import cats.syntax.all._
 import com.sksamuel.avro4s.{
   DecoderHelpers,
   EncoderHelpers,

diff --git a/...n/scala/com/github/chenharryhua/nanjin/messages/kafka/codec/NJConsumerRecordDecoder.scala b/...n/scala/com/github/chenharryhua/nanjin/messages/kafka/codec/NJConsumerRecordDecoder.scala
@@ -1,7 +1,7 @@
 package com.github.chenharryhua.nanjin.messages.kafka.codec
 
 import cats.data.{Chain, Writer}
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.messages.kafka._
 import org.apache.kafka.common.serialization.Deserializer
 

diff --git a/messages/src/test/scala/mtest/codec/PrismTest.scala b/messages/src/test/scala/mtest/codec/PrismTest.scala
@@ -1,7 +1,6 @@
 package mtest.codec
 
 import cats.Eq
-import cats.implicits._
 import com.github.chenharryhua.nanjin.messages.kafka._
 import com.github.chenharryhua.nanjin.messages.kafka.codec.KJson
 import monocle.law.discipline.PrismTests

diff --git a/messages/src/test/scala/mtest/kafka/ArbitraryData.scala b/messages/src/test/scala/mtest/kafka/ArbitraryData.scala
@@ -18,7 +18,7 @@ import fs2.kafka.{
 import org.apache.kafka.clients.consumer.ConsumerRecord
 import org.apache.kafka.clients.producer.ProducerRecord
 import org.scalacheck.{Arbitrary, Cogen, Gen}
-import cats.implicits._
+import cats.syntax.all._
 import com.github.chenharryhua.nanjin.messages.kafka.{NJProducerRecord, OptionalKV}
 
 final case class PrimitiveTypeCombined(

diff --git a/messages/src/test/scala/mtest/kafka/BimapNJRecords.scala b/messages/src/test/scala/mtest/kafka/BimapNJRecords.scala
@@ -1,7 +1,6 @@
 package mtest.kafka
 
 import cats.derived.auto.eq._
-import cats.implicits._
 import cats.kernel.laws.discipline.{LowerBoundedTests, OrderTests}
 import cats.laws.discipline.BifunctorTests
 import com.github.chenharryhua.nanjin.messages.kafka._