Reformat with scalafmt 3.8.6

Executed command: scalafmt --non-interactive

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))