Update scalafmt-core to 3.8.5

.git-blame-ignore-revs

@@ -12,3 +12,6 @@ d12fb4427a1ccff4660b6c559b858adfe4eebaf0
 
 # Scala Steward: Reformat with scalafmt 3.8.3
 3f4adc5fafe17c8de66876d3a93a8eb54e1d65d3
+
+# Scala Steward: Reformat with scalafmt 3.8.5
+1561c4c81d5e6f12c6025b46fd7d9faca352693a

.scalafmt.conf

@@ -1,4 +1,4 @@
-version                                  = 3.8.3
+version                                  = 3.8.5
 runner.dialect                           = scala213
 project.git                              = true
 style                                    = defaultWithAlign

benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/PerfFixtureHelpers.scala

@@ -46,7 +46,7 @@ object PerfFixtureHelpers {
 private[benchmarks] trait PerfFixtureHelpers extends LazyLogging {
   import PerfFixtureHelpers._
 
-  val producerTimeout = 6 minutes
+  val producerTimeout = 6.minutes
   val logPercentStep = 25
   val adminClientCloseTimeout = Duration.ofSeconds(5)
   val producerCloseTimeout = adminClientCloseTimeout

benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaConsumerBenchmarks.scala

@@ -36,7 +36,7 @@ import scala.language.postfixOps
 import scala.util.Success
 
 object ReactiveKafkaConsumerBenchmarks extends LazyLogging with InflightMetrics {
-  val streamingTimeout: FiniteDuration = 30 minutes
+  val streamingTimeout: FiniteDuration = 30.minutes
   type NonCommittableFixture = ReactiveKafkaConsumerTestFixture[ConsumerRecord[Array[Byte], String]]
   type CommittableFixture = ReactiveKafkaConsumerTestFixture[CommittableMessage[Array[Byte], String]]
 

benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaProducerBenchmarks.scala

@@ -30,7 +30,7 @@ import scala.concurrent.duration._
 import scala.language.postfixOps
 
 object ReactiveKafkaProducerBenchmarks extends LazyLogging {
-  val streamingTimeout = 30 minutes
+  val streamingTimeout = 30.minutes
   val logStep = 100000
 
   type Fixture = ReactiveKafkaConsumerTestFixture[CommittableMessage[Array[Byte], String]]

benchmarks/src/main/scala/org/apache/pekko/kafka/benchmarks/ReactiveKafkaTransactionBenchmarks.scala

@@ -30,7 +30,7 @@ import scala.language.postfixOps
 import scala.util.Success
 
 object ReactiveKafkaTransactionBenchmarks extends LazyLogging {
-  val streamingTimeout: FiniteDuration = 30 minutes
+  val streamingTimeout: FiniteDuration = 30.minutes
   type TransactionFixture = ReactiveKafkaTransactionTestFixture[KTransactionMessage, KProducerMessage, KResult]
 
   /**

build.sbt

@@ -135,8 +135,7 @@ lazy val docs = project
     Preprocess / siteSubdirName := s"api/pekko-connectors-kafka/${projectInfoVersion.value}",
     Preprocess / sourceDirectory := (LocalRootProject / ScalaUnidoc / unidoc / target).value,
     Preprocess / preprocessRules := Seq(
-      ("\\.java\\.scala".r, _ => ".java"),
-      ("https://javadoc\\.io/page/".r, _ => "https://javadoc\\.io/static/"),
+      ("\\.java\\.scala".r, _ => ".java"), ("https://javadoc\\.io/page/".r, _ => "https://javadoc\\.io/static/"),
       // bug in Scaladoc
       ("https://docs\\.oracle\\.com/en/java/javase/11/docs/api/java.base/java/time/Duration\\$.html".r,
         _ => "https://docs\\.oracle\\.com/en/java/javase/11/docs/api/java.base/java/time/Duration.html"),

tests/src/test/scala/org/apache/pekko/kafka/scaladsl/MetadataClientSpec.scala

@@ -31,7 +31,7 @@ class MetadataClientSpec extends SpecBase with TestcontainersKafkaLike {
       val partition0 = new TopicPartition(topic1, 0)
       val consumerSettings = consumerDefaults.withGroupId(group1)
 
-      val metadataClient = MetadataClient.create(consumerSettings, 1 second)
+      val metadataClient = MetadataClient.create(consumerSettings, 1.second)
 
       awaitProduce(produce(topic1, 1 to 10))
 
@@ -49,7 +49,7 @@ class MetadataClientSpec extends SpecBase with TestcontainersKafkaLike {
       val nonExistingPartition = new TopicPartition("non-existing topic", 0)
       val consumerSettings = consumerDefaults.withGroupId(group1)
 
-      val metadataClient = MetadataClient.create(consumerSettings, 1 second)
+      val metadataClient = MetadataClient.create(consumerSettings, 1.second)
 
       val beginningOffsetsFuture = metadataClient
         .getBeginningOffsets(Set(nonExistingPartition))
@@ -65,7 +65,7 @@ class MetadataClientSpec extends SpecBase with TestcontainersKafkaLike {
       val partition0 = new TopicPartition(topic1, 0)
       val consumerSettings = consumerDefaults.withGroupId(group1)
 
-      val metadataClient = MetadataClient.create(consumerSettings, 1 second)
+      val metadataClient = MetadataClient.create(consumerSettings, 1.second)
 
       awaitProduce(produce(topic1, 1 to 10))
 
@@ -83,7 +83,7 @@ class MetadataClientSpec extends SpecBase with TestcontainersKafkaLike {
       val group1 = createGroupId(1)
       val partition0 = new TopicPartition(topic1, 0)
       val consumerSettings = consumerDefaults.withGroupId(group1)
-      val metadataClient = MetadataClient.create(consumerSettings, 1 second)
+      val metadataClient = MetadataClient.create(consumerSettings, 1.second)
 
       awaitProduce(produce(topic1, 1 to 10))
 
@@ -98,7 +98,7 @@ class MetadataClientSpec extends SpecBase with TestcontainersKafkaLike {
       val group1 = createGroupId(1)
       val nonExistingPartition = new TopicPartition("non-existing topic", 0)
       val consumerSettings = consumerDefaults.withGroupId(group1)
-      val metadataClient = MetadataClient.create(consumerSettings, 1 second)
+      val metadataClient = MetadataClient.create(consumerSettings, 1.second)
 
       val endOffsetsFuture = metadataClient.getEndOffsets(Set(nonExistingPartition))
 
@@ -112,7 +112,7 @@ class MetadataClientSpec extends SpecBase with TestcontainersKafkaLike {
       val group1 = createGroupId(1)
       val partition0 = new TopicPartition(topic1, 0)
       val consumerSettings = consumerDefaults.withGroupId(group1)
-      val metadataClient = MetadataClient.create(consumerSettings, 1 second)
+      val metadataClient = MetadataClient.create(consumerSettings, 1.second)
 
       awaitProduce(produce(topic1, 1 to 10))
 
@@ -128,7 +128,7 @@ class MetadataClientSpec extends SpecBase with TestcontainersKafkaLike {
       val topic1 = createTopic(suffix = 1, partitions = 2)
       val topic2 = createTopic(suffix = 2, partitions = 1)
       val consumerSettings = consumerDefaults.withGroupId(group)
-      val metadataClient = MetadataClient.create(consumerSettings, 1 second)
+      val metadataClient = MetadataClient.create(consumerSettings, 1.second)
 
       awaitProduce(produce(topic1, 1 to 10, partition = 0))
       awaitProduce(produce(topic1, 1 to 10, partition = 1))
@@ -148,7 +148,7 @@ class MetadataClientSpec extends SpecBase with TestcontainersKafkaLike {
       val group = createGroupId(1)
       val topic = createTopic(suffix = 1, partitions = 2)
       val consumerSettings = consumerDefaults.withGroupId(group)
-      val metadataClient = MetadataClient.create(consumerSettings, 1 second)
+      val metadataClient = MetadataClient.create(consumerSettings, 1.second)
 
       awaitProduce(produce(topic, 1 to 10, partition = 0))
       awaitProduce(produce(topic, 1 to 10, partition = 1))