Update scalafmt-core to 3.8.2 (#505)

* Update scalafmt-core to 3.8.2

* Reformat with scalafmt 3.8.2

Executed command: scalafmt --non-interactive

* Add 'Reformat with scalafmt 3.8.2' to .git-blame-ignore-revs

Author: scala-steward

.git-blame-ignore-revs

@@ -1,2 +1,5 @@
 # Scala Steward: Reformat with scalafmt 3.7.13
 45a8fb5960229db62e2efc7f721538a34717424c
+
+# Scala Steward: Reformat with scalafmt 3.8.2
+e77fecfd3d411d51d9d555396647a190b50cf59d

.scalafmt.conf

@@ -1,4 +1,4 @@
-version = 3.8.1
+version = 3.8.2
 preset = defaultWithAlign
 docstrings.blankFirstLine = yes
 newlines.implicitParamListModifierPrefer = before

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

@@ -298,8 +298,8 @@ trait ConsumerOps[C <: EmbeddedKafkaConfig] {
         while (recordIter.hasNext && messagesRead < number) {
           val record = recordIter.next
           messagesBuffers(record.topic) += (record.key -> record.value)
-          val tp = new TopicPartition(record.topic, record.partition)
-          val om = new OffsetAndMetadata(record.offset + 1)
+          val tp     = new TopicPartition(record.topic, record.partition)
+          val om     = new OffsetAndMetadata(record.offset + 1)
           consumer.commitSync(Map(tp -> om).asJava)
           messagesRead += 1
         }