diff --git a/modules/kafka/src/test/scala/com/snowplowanalytics/snowplow/enrich/kafka/ConfigSpec.scala b/modules/kafka/src/test/scala/com/snowplowanalytics/snowplow/enrich/kafka/ConfigSpec.scala index 054c5916c..71d8178ce 100644 --- a/modules/kafka/src/test/scala/com/snowplowanalytics/snowplow/enrich/kafka/ConfigSpec.scala +++ b/modules/kafka/src/test/scala/com/snowplowanalytics/snowplow/enrich/kafka/ConfigSpec.scala @@ -92,7 +92,7 @@ class ConfigSpec extends Specification with CatsEffect { ) ) ), - io.Concurrency(256, 1), + io.Concurrency(256, 8), Some(7.days), io.RemoteAdapterConfigs( 10.seconds, @@ -202,7 +202,7 @@ class ConfigSpec extends Specification with CatsEffect { ) ) ), - io.Concurrency(256, 1), + io.Concurrency(256, 8), None, io.RemoteAdapterConfigs( 10.seconds, diff --git a/modules/kinesis/src/test/scala/com/snowplowanalytics/snowplow/enrich/kinesis/ConfigSpec.scala b/modules/kinesis/src/test/scala/com/snowplowanalytics/snowplow/enrich/kinesis/ConfigSpec.scala index c7ad3136b..350342327 100644 --- a/modules/kinesis/src/test/scala/com/snowplowanalytics/snowplow/enrich/kinesis/ConfigSpec.scala +++ b/modules/kinesis/src/test/scala/com/snowplowanalytics/snowplow/enrich/kinesis/ConfigSpec.scala @@ -81,7 +81,7 @@ class ConfigSpec extends Specification with CatsEffect { None ) ), - io.Concurrency(256, 1), + io.Concurrency(256, 8), Some(7.days), io.RemoteAdapterConfigs( 10.seconds, @@ -175,7 +175,7 @@ class ConfigSpec extends Specification with CatsEffect { None ) ), - io.Concurrency(256, 1), + io.Concurrency(256, 8), None, io.RemoteAdapterConfigs( 10.seconds,