Reformat with scalafmt 3.9.7

Executed command: scalafmt --non-interactive

Author: scala-steward

build.sbt

@@ -24,7 +24,7 @@ lazy val publishSettings = Seq(
   homepage := Some(url("https://github.com/embeddedkafka/embedded-kafka")),
   licenses += ("MIT", url("https://opensource.org/licenses/MIT")),
   Test / publishArtifact := false,
-  developers := List(
+  developers             := List(
     Developer(
       "manub",
       "Emanuele Blanco",
@@ -72,8 +72,8 @@ lazy val testSettings = Seq(
 )
 
 lazy val commonSettings = Seq(
-  organization := "io.github.embeddedkafka",
-  scalaVersion := Versions.Scala213,
+  organization       := "io.github.embeddedkafka",
+  scalaVersion       := Versions.Scala213,
   crossScalaVersions := Seq(
     Versions.Scala213,
     Versions.Scala3

embedded-kafka/src/main/scala/io/github/embeddedkafka/Codecs.scala

@@ -8,7 +8,7 @@ import org.apache.kafka.common.serialization._
   * decoders
   */
 object Codecs {
-  implicit val stringSerializer: Serializer[String] = new StringSerializer()
+  implicit val stringSerializer: Serializer[String]    = new StringSerializer()
   implicit val nullSerializer: Serializer[Array[Byte]] =
     new ByteArraySerializer()
 

embedded-kafka/src/main/scala/io/github/embeddedkafka/ops/ConsumerOps.scala

@@ -275,7 +275,7 @@ trait ConsumerOps[C <: EmbeddedKafkaConfig] {
     )
 
     var timeoutNanoTime = System.nanoTime + timeout.toNanos
-    val consumer = new KafkaConsumer[K, V](
+    val consumer        = new KafkaConsumer[K, V](
       consumerProperties.asJava,
       keyDeserializer,
       valueDeserializer

embedded-kafka/src/test/scala/io/github/embeddedkafka/EmbeddedKafkaMethodsSpec.scala

@@ -29,7 +29,7 @@ class EmbeddedKafkaMethodsSpec
     with OptionValues
     with JavaFutures {
   private val consumerPollTimeout: FiniteDuration = 5.seconds
-  private implicit val patience: PatienceConfig =
+  private implicit val patience: PatienceConfig   =
     PatienceConfig(Span(5, Seconds), Span(100, Milliseconds))
 
   override def beforeAll(): Unit = {
@@ -70,7 +70,7 @@ class EmbeddedKafkaMethodsSpec
       val message                                   = "hello world!"
       val topic       = "publish_test_topic_with_header"
       val headerValue = "my_header_value"
-      val headers = new RecordHeaders()
+      val headers     = new RecordHeaders()
         .add("my_header", headerValue.toCharArray.map(_.toByte))
       val producerRecord =
         new ProducerRecord[String, String](topic, null, "key", message, headers)
@@ -308,8 +308,8 @@ class EmbeddedKafkaMethodsSpec
     }
 
     "return a message published to a topic with custom decoder" in {
-      val message = TestClass("name")
-      val topic   = "consume_test_topic"
+      val message                                        = TestClass("name")
+      val topic                                          = "consume_test_topic"
       implicit val deserializer: Deserializer[TestClass] =
         new TestJsonDeserializer[TestClass]
 
@@ -364,9 +364,9 @@ class EmbeddedKafkaMethodsSpec
     }
 
     "return a message published to a topic with custom decoders" in {
-      val key     = TestClass("key")
-      val message = TestClass("message")
-      val topic   = "consume_test_topic"
+      val key                                            = TestClass("key")
+      val message                                        = TestClass("message")
+      val topic                                          = "consume_test_topic"
       implicit val deserializer: Deserializer[TestClass] =
         new TestJsonDeserializer[TestClass]
       val serializer = new TestJsonSerializer[TestClass]
@@ -389,9 +389,9 @@ class EmbeddedKafkaMethodsSpec
     }
 
     "return a message published to a topic with 2 different decoders" in {
-      val key     = "key"
-      val message = TestClass("message")
-      val topic   = "consume_test_topic"
+      val key                                             = "key"
+      val message                                         = TestClass("message")
+      val topic                                           = "consume_test_topic"
       implicit val stringDeserializer: StringDeserializer =
         new StringDeserializer
       implicit val deserializer: Deserializer[TestClass] =
@@ -478,7 +478,7 @@ class EmbeddedKafkaMethodsSpec
 
   "the consumeNumberMessagesFromTopics method" should {
     "consume from multiple topics" in {
-      val config = EmbeddedKafkaConfig()
+      val config           = EmbeddedKafkaConfig()
       val topicMessagesMap = Map(
         "topic1" -> List("message 1"),
         "topic2" -> List("message 2a", "message 2b")
@@ -501,7 +501,7 @@ class EmbeddedKafkaMethodsSpec
       producer.flush()
 
       implicit val deserializer: StringDeserializer = new StringDeserializer
-      val consumedMessages =
+      val consumedMessages                          =
         consumeNumberMessagesFromTopics(
           topicMessagesMap.keySet,
           topicMessagesMap.values.map(_.size).sum
@@ -517,7 +517,7 @@ class EmbeddedKafkaMethodsSpec
 
   "the consumeNumberKeyedMessagesFromTopics method" should {
     "consume from multiple topics" in {
-      val config = EmbeddedKafkaConfig()
+      val config           = EmbeddedKafkaConfig()
       val topicMessagesMap =
         Map(
           "topic1" -> List(("m1", "message 1")),
@@ -541,7 +541,7 @@ class EmbeddedKafkaMethodsSpec
       producer.flush()
 
       implicit val deserializer: StringDeserializer = new StringDeserializer
-      val consumedMessages =
+      val consumedMessages                          =
         consumeNumberKeyedMessagesFromTopics(
           topicMessagesMap.keySet,
           topicMessagesMap.values.map(_.size).sum

kafka-connect/src/main/scala/io/github/embeddedkafka/connect/EmbeddedKafkaConnect.scala

@@ -67,7 +67,7 @@ private[embeddedkafka] trait EmbeddedKafkaConnectSupport[
       )
       val standaloneConfig = new StandaloneConfig(configMap.asJava)
       val restClient       = new RestClient(standaloneConfig)
-      val rest = new ConnectRestServer(
+      val rest             = new ConnectRestServer(
         standaloneConfig.rebalanceTimeout,
         restClient,
         configMap.asJava
@@ -95,7 +95,7 @@ private[embeddedkafka] trait EmbeddedKafkaConnectSupport[
       offsetBackingStore.configure(standaloneConfig)
 
       val workerId = s"localhost:$connectPort"
-      val worker = new Worker(
+      val worker   = new Worker(
         workerId,
         Time.SYSTEM,
         plugins,
@@ -104,7 +104,7 @@ private[embeddedkafka] trait EmbeddedKafkaConnectSupport[
         connectorClientConfigOverridePolicy
       )
       val clusterId = standaloneConfig.kafkaClusterId()
-      val herder = new StandaloneHerder(
+      val herder    = new StandaloneHerder(
         worker,
         clusterId,
         connectorClientConfigOverridePolicy

kafka-streams/src/main/scala/io/github/embeddedkafka/streams/EmbeddedKafkaStreams.scala

@@ -88,7 +88,7 @@ private[embeddedkafka] trait EmbeddedKafkaStreamsSupport[
     withRunningKafkaOnFoundPort(config) { implicit configWithUsedPorts =>
       topicsToCreate.foreach(topic => createCustomTopic(topic))
       val streamId = UUIDs.newUuid().toString
-      val streams = new KafkaStreams(
+      val streams  = new KafkaStreams(
         topology,
         map2Properties(streamsConfig.config(streamId, extraConfig))
       )

kafka-streams/src/test/scala/io/github/embeddedkafka/streams/ExampleKafkaStreamsSpec.scala

@@ -27,7 +27,7 @@ class ExampleKafkaStreamsSpec
       implicit val config: EmbeddedKafkaConfig =
         EmbeddedKafkaConfig(kafkaPort = 7000, controllerPort = 7001)
 
-      val streamBuilder = new StreamsBuilder
+      val streamBuilder                   = new StreamsBuilder
       val stream: KStream[String, String] =
         streamBuilder.stream(inTopic, Consumed.`with`(stringSerde, stringSerde))
 
@@ -56,7 +56,7 @@ class ExampleKafkaStreamsSpec
       val userDefinedConfig: EmbeddedKafkaConfig =
         EmbeddedKafkaConfig(kafkaPort = 0, controllerPort = 0)
 
-      val streamBuilder = new StreamsBuilder
+      val streamBuilder                   = new StreamsBuilder
       val stream: KStream[String, String] =
         streamBuilder.stream(inTopic, Consumed.`with`(stringSerde, stringSerde))
 
@@ -91,7 +91,7 @@ class ExampleKafkaStreamsSpec
       implicit val patienceConfig: PatienceConfig =
         PatienceConfig(5.seconds, 100.millis)
 
-      val streamBuilder = new StreamsBuilder
+      val streamBuilder                   = new StreamsBuilder
       val stream: KStream[String, String] =
         streamBuilder.stream(inTopic, Consumed.`with`(stringSerde, stringSerde))