diff --git a/.git-blame-ignore-revs b/.git-blame-ignore-revs
index a7842987..443b135b 100644
--- a/.git-blame-ignore-revs
+++ b/.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
diff --git a/.scalafmt.conf b/.scalafmt.conf
index e667c448..7cf9b0a3 100644
--- a/.scalafmt.conf
+++ b/.scalafmt.conf
@@ -1,4 +1,4 @@
-version = 3.8.1
+version = 3.8.2
 preset = defaultWithAlign
 docstrings.blankFirstLine = yes
 newlines.implicitParamListModifierPrefer = before
diff --git a/embedded-kafka/src/main/scala/io/github/embeddedkafka/ops/ConsumerOps.scala b/embedded-kafka/src/main/scala/io/github/embeddedkafka/ops/ConsumerOps.scala
index c7929e6f..1d1d5f7e 100644
--- a/embedded-kafka/src/main/scala/io/github/embeddedkafka/ops/ConsumerOps.scala
+++ b/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
         }