diff --git a/journal/src/test/scala/com/evolutiongaming/kafka/journal/ActionHeaderJsonSpec.scala b/journal/src/test/scala/com/evolutiongaming/kafka/journal/ActionHeaderJsonSpec.scala
index d0aacfb70..11dbbc3d7 100644
--- a/journal/src/test/scala/com/evolutiongaming/kafka/journal/ActionHeaderJsonSpec.scala
+++ b/journal/src/test/scala/com/evolutiongaming/kafka/journal/ActionHeaderJsonSpec.scala
@@ -42,10 +42,10 @@ class ActionHeaderJsonSpec extends AnyFunSuite with Matchers {
     }
 
     test(s"Delete format, origin: $origin") {
-      val seqNr  = SeqNr.unsafe(3)
+      val seqNr = SeqNr.unsafe(3)
       val version = origin match {
         case Some(_) => Version("0.0.1")
-        case None => Version.obsolete
+        case None    => Version.obsolete
       }
       val header = ActionHeader.Delete(seqNr.toDeleteTo, origin, version)
       verify(header, s"Delete-$originStr")
@@ -54,7 +54,7 @@ class ActionHeaderJsonSpec extends AnyFunSuite with Matchers {
     test(s"Purge format, origin: $origin") {
       val version = origin match {
         case Some(_) => Version("0.0.1")
-        case None => Version.obsolete
+        case None    => Version.obsolete
       }
       val header = ActionHeader.Purge(origin, version)
       verify(header, s"Purge-$originStr")
@@ -63,7 +63,7 @@ class ActionHeaderJsonSpec extends AnyFunSuite with Matchers {
     test(s"Mark format, origin: $origin") {
       val version = origin match {
         case Some(_) => Version("0.0.1")
-        case None => Version.obsolete
+        case None    => Version.obsolete
       }
       val header = ActionHeader.Mark("id", origin, version)
       verify(header, s"Mark-$originStr")
diff --git a/replicator/src/main/scala/com/evolutiongaming/kafka/journal/replicator/ReplicateRecords.scala b/replicator/src/main/scala/com/evolutiongaming/kafka/journal/replicator/ReplicateRecords.scala
index 42b473d5a..4cae79d99 100644
--- a/replicator/src/main/scala/com/evolutiongaming/kafka/journal/replicator/ReplicateRecords.scala
+++ b/replicator/src/main/scala/com/evolutiongaming/kafka/journal/replicator/ReplicateRecords.scala
@@ -113,7 +113,7 @@ private[journal] object ReplicateRecords {
         def delete(offset: Offset, deleteTo: DeleteTo, origin: Option[Origin], version: Version): F[Int] = {
 
           def msg(latency: FiniteDuration): String = {
-            val originStr  = origin.foldMap { origin => s", origin: $origin" }
+            val originStr = origin.foldMap { origin => s", origin: $origin" }
             s"delete in ${latency.toMillis}ms, id: $id, offset: $partition:$offset, deleteTo: $deleteTo$originStr, version: $version"
           }
 
@@ -135,7 +135,7 @@ private[journal] object ReplicateRecords {
         def purge(offset: Offset, origin: Option[Origin], version: Version): F[Int] = {
 
           def msg(latency: FiniteDuration): String = {
-            val originStr  = origin.foldMap { origin => s", origin: $origin" }
+            val originStr = origin.foldMap { origin => s", origin: $origin" }
             s"purge in ${latency.toMillis}ms, id: $id, offset: $partition:$offset$originStr, version: $version"
           }