diff --git a/cassandra/src/test/scala/com/evolutiongaming/kafka/journal/cassandra/SettingsCassandraSpec.scala b/cassandra/src/test/scala/com/evolutiongaming/kafka/journal/cassandra/SettingsCassandraSpec.scala
index a0108455a..8813edd02 100644
--- a/cassandra/src/test/scala/com/evolutiongaming/kafka/journal/cassandra/SettingsCassandraSpec.scala
+++ b/cassandra/src/test/scala/com/evolutiongaming/kafka/journal/cassandra/SettingsCassandraSpec.scala
@@ -87,10 +87,10 @@ class SettingsCassandraSpec extends AnyFunSuite {
   private val settings = {
 
     val statements = SettingsCassandra.Statements(
-      select        = Database.select(_),
-      insert        = Database.insert(_),
-      all           = Database.all,
-      delete        = Database.delete(_),
+      select = Database.select(_),
+      insert = Database.insert(_),
+      all    = Database.all,
+      delete = Database.delete(_),
     )
 
     implicit val clock: Clock[F] = Clock.const[F](nanos = 0, millis = timestamp.toEpochMilli)
diff --git a/eventual-cassandra/src/test/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/EventualCassandraTest.scala b/eventual-cassandra/src/test/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/EventualCassandraTest.scala
index da88187ef..8b5602a88 100644
--- a/eventual-cassandra/src/test/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/EventualCassandraTest.scala
+++ b/eventual-cassandra/src/test/scala/com/evolutiongaming/kafka/journal/eventual/cassandra/EventualCassandraTest.scala
@@ -55,7 +55,7 @@ class EventualCassandraTest extends AnyFunSuite with Matchers {
   } {
     implicit val log = Log.empty[StateT]
 
-    val config = DataIntegrityConfig(
+  val config = DataIntegrityConfig(
       seqNrUniqueness         = true,
       correlateEventsWithMeta = true,
     )
@@ -63,7 +63,7 @@ class EventualCassandraTest extends AnyFunSuite with Matchers {
     val segmentOf    = SegmentOf[Id](segments)
     val segmentNrsOf = SegmentNrsOf[StateT](first = segments, Segments.default)
     val statements   = statementsOf(segmentNrsOf, Segments.default)
-    val journal      = EventualCassandra(statements, DataIntegrityConfig.Default)
+    val journal      = EventualCassandra(statements, config)
 
     val suffix = s"segmentSize: $segmentSize, segments: $segments"
 
diff --git a/journal/src/test/scala/com/evolutiongaming/kafka/journal/HeadCacheSpec.scala b/journal/src/test/scala/com/evolutiongaming/kafka/journal/HeadCacheSpec.scala
index 1136adfef..fed2e8f65 100644
--- a/journal/src/test/scala/com/evolutiongaming/kafka/journal/HeadCacheSpec.scala
+++ b/journal/src/test/scala/com/evolutiongaming/kafka/journal/HeadCacheSpec.scala
@@ -285,7 +285,8 @@ object HeadCacheSpec {
 
     for {
       metrics <- HeadCacheMetrics.make[IO](CollectorRegistry.empty)
-      headCache <- HeadCache.make[IO](log = LogIO, config = config, eventual = eventual, consumer = consumer, metrics = metrics.some)
+      headCache <- HeadCache
+        .make[IO](log = LogIO, config = config, eventual = eventual, consumer = consumer, metrics = metrics.some)
     } yield headCache
   }
 
diff --git a/tests/src/test/scala/com/evolutiongaming/kafka/journal/IntegrationSuite.scala b/tests/src/test/scala/com/evolutiongaming/kafka/journal/IntegrationSuite.scala
index b2c6815df..7fe4d8be1 100644
--- a/tests/src/test/scala/com/evolutiongaming/kafka/journal/IntegrationSuite.scala
+++ b/tests/src/test/scala/com/evolutiongaming/kafka/journal/IntegrationSuite.scala
@@ -25,7 +25,7 @@ object IntegrationSuite {
       // To ensure all default '127.0.0.1:9042' configurations work, we need to bind to the host's 9042 port manually
       Resource.make {
         Sync[F].delay {
-          val cassandra =  CassandraContainer
+          val cassandra = CassandraContainer
             .apply()
             .configure { container =>
               container.withCreateContainerCmdModifier { cmd =>
@@ -73,8 +73,7 @@ object IntegrationSuite {
         metrics  <- Replicator.Metrics.make[F](CollectorRegistry.empty[F], "clientId")
         config   <- config.toResource
         hostName <- HostName.of[F]().toResource
-        result   <- Replicator.make
-        [F](config, cassandraClusterOf, hostName, metrics.some)
+        result   <- Replicator.make[F](config, cassandraClusterOf, hostName, metrics.some)
         _        <- result.onError { case e => log.error(s"failed to release replicator with $e", e) }.background
       } yield {}
     }