Add -Xsource:3 (#675)

* Add -Xsource:3; fix compiler warnings; use wildcard for imports

Author: Z1kkurat

.scalafmt.conf

@@ -2,7 +2,7 @@
 // https://scalameta.org/scalafmt/docs/configuration.html
 project.git = true
 
-runner.dialect = scala213
+runner.dialect = scala213source3
 
 version = 3.7.14
 

build.sbt

@@ -1,4 +1,4 @@
-import Dependencies._
+import Dependencies.*
 
 ThisBuild / versionScheme := Some("early-semver")
 ThisBuild / evictionErrorLevel := Level.Warn
@@ -21,6 +21,7 @@ lazy val commonSettings = Seq(
     "org.scala-lang.modules" %% "scala-java8-compat" % "always"
   ),
   addCompilerPlugin("org.typelevel" %% "kind-projector" % "0.13.3" cross CrossVersion.full),
+  scalacOptions ++= Seq("-Xsource:3"),
 )
 
 lazy val root = (project in file("."))

core-it-tests/src/test/scala/com/evolutiongaming/kafka/flow/ShutdownSpec.scala

@@ -3,7 +3,7 @@ package com.evolutiongaming.kafka.flow
 import cats.data.{NonEmptyList, NonEmptySet}
 import cats.effect.unsafe.IORuntime
 import cats.effect.{Deferred, IO, Ref, Resource}
-import cats.syntax.all._
+import cats.syntax.all.*
 import com.evolutiongaming.catshelper.LogOf
 import com.evolutiongaming.retry.Retry
 import com.evolutiongaming.skafka.consumer.ConsumerRecords
@@ -12,7 +12,7 @@ import com.evolutiongaming.skafka.{CommonConfig, Offset, Partition}
 import com.evolutiongaming.sstream.Stream
 import scodec.bits.ByteVector
 
-import scala.concurrent.duration._
+import scala.concurrent.duration.*
 
 class ShutdownSpec extends ForAllKafkaSuite {
 

core/src/main/scala/com/evolutiongaming/kafka/flow/AdditionalStatePersist.scala

@@ -1,9 +1,9 @@
 package com.evolutiongaming.kafka.flow
 
 import cats.Applicative
-import cats.effect.syntax.all._
+import cats.effect.syntax.all.*
 import cats.effect.{Clock, MonadCancel, MonadCancelThrow, Ref}
-import cats.syntax.all._
+import cats.syntax.all.*
 import com.evolutiongaming.kafka.flow.kafka.OffsetToCommit
 import com.evolutiongaming.kafka.flow.persistence.Persistence
 import com.evolutiongaming.skafka.consumer.ConsumerRecord

core/src/main/scala/com/evolutiongaming/kafka/flow/ConsumerFlow.scala

@@ -3,7 +3,7 @@ package com.evolutiongaming.kafka.flow
 import cats.MonadThrow
 import cats.data.NonEmptySet
 import cats.effect.Resource
-import cats.syntax.all._
+import cats.syntax.all.*
 import com.evolutiongaming.catshelper.{Log, LogOf}
 import com.evolutiongaming.kafka.flow.kafka.Consumer
 import com.evolutiongaming.skafka.Topic

core/src/main/scala/com/evolutiongaming/kafka/flow/ConsumerFlowConfig.scala

@@ -1,6 +1,6 @@
 package com.evolutiongaming.kafka.flow
 
-import scala.concurrent.duration._
+import scala.concurrent.duration.*
 
 /** Configuration of `ConsumerFlow`.
   *

core/src/main/scala/com/evolutiongaming/kafka/flow/EnhancedFold.scala

@@ -1,6 +1,6 @@
 package com.evolutiongaming.kafka.flow
 
-import cats.syntax.all._
+import cats.syntax.all.*
 import cats.{Applicative, ApplicativeError, Monad}
 
 /** Given an optional state `S` and an incoming event `E`, produces a resulting optional state `S`. This is the main

core/src/main/scala/com/evolutiongaming/kafka/flow/Fold.scala

@@ -4,7 +4,7 @@ import cats.Applicative
 import cats.ApplicativeError
 import cats.Functor
 import cats.Monad
-import cats.syntax.all._
+import cats.syntax.all.*
 
 /** Reads a state and effectfully produces a new one.
   *

core/src/main/scala/com/evolutiongaming/kafka/flow/FoldOption.scala

@@ -4,7 +4,7 @@ import cats.Applicative
 import cats.ApplicativeError
 import cats.Functor
 import cats.Monad
-import cats.syntax.all._
+import cats.syntax.all.*
 
 /** Convenience methods for using `Fold` with optional state */
 final case class FoldOption[F[_], S, A](value: Fold[F, Option[S], A]) {

core/src/main/scala/com/evolutiongaming/kafka/flow/FoldToState.scala

@@ -4,8 +4,8 @@ import cats.Monad
 import cats.data.NonEmptyList
 import cats.effect.{Ref, Sync}
 import cats.mtl.Stateful
-import cats.syntax.all._
-import com.evolutiongaming.kafka.flow.effect.CatsEffectMtlInstances._
+import cats.syntax.all.*
+import com.evolutiongaming.kafka.flow.effect.CatsEffectMtlInstances.*
 import com.evolutiongaming.kafka.flow.persistence.Persistence
 
 /** Applies records to a state stored inside and informs the listeners about the changes */