Increase sleep time in Kinesis integration tests (#30)

It fixes the flaky tests.

Author: spenes

kinesis/src/it/scala/com/snowplowanalytics/snowplow/collectors/scalastream/it/core/CustomPathsSpec.scala

@@ -48,7 +48,7 @@ class CustomPathsSpec extends Specification with Localstack with CatsEffect {
 
         for {
           _ <- Http.statuses(requests)
-          _ <- IO.sleep(5.second)
+          _ <- IO.sleep(30.second)
           collectorOutput <- Kinesis.readOutput(streamGood, streamBad)
           outputPaths = collectorOutput.good.sortBy(_.getTimestamp()).map(_.getPath())
         } yield {

kinesis/src/it/scala/com/snowplowanalytics/snowplow/collectors/scalastream/it/core/DoNotTrackCookieSpec.scala

@@ -52,7 +52,7 @@ class DoNotTrackCookieSpec extends Specification with Localstack with CatsEffect
 
         for {
           statuses <- Http.statuses(requests)
-          _ <- IO.sleep(5.second)
+          _ <- IO.sleep(30.second)
           collectorOutput <- Kinesis.readOutput(streamGood, streamBad)
           headers = collectorOutput.good.map(_.headers.asScala)
         } yield {
@@ -80,7 +80,7 @@ class DoNotTrackCookieSpec extends Specification with Localstack with CatsEffect
 
         for {
           status <- Http.status(request)
-          _ <- IO.sleep(5.second)
+          _ <- IO.sleep(30.second)
           collectorOutput <- Kinesis.readOutput(streamGood, streamBad)
           headers = collectorOutput.good.map(_.headers.asScala)
         } yield {

kinesis/src/it/scala/com/snowplowanalytics/snowplow/collectors/scalastream/it/core/HealthEndpointSpec.scala

@@ -40,7 +40,7 @@ class HealthEndpointSpec extends Specification with Localstack with CatsEffect {
 
         for {
           status <- Http.status(request)
-          _ <- IO.sleep(5.second)
+          _ <- IO.sleep(30.second)
           collectorOutput <- Kinesis.readOutput(streamGood, streamBad)
         } yield {
           status.code must beEqualTo(200)

kinesis/src/it/scala/com/snowplowanalytics/snowplow/collectors/scalastream/it/core/XForwardedForSpec.scala

@@ -45,7 +45,7 @@ class XForwardedForSpec extends Specification with Localstack with CatsEffect {
 
         for {
           _ <- Http.status(request)
-          _ <- IO.sleep(5.second)
+          _ <- IO.sleep(30.second)
           collectorOutput <- Kinesis.readOutput(streamGood, streamBad)
         } yield {
           val expected = "X-Forwarded-For: 123.123.123.123"

kinesis/src/it/scala/com/snowplowanalytics/snowplow/collectors/scalastream/it/kinesis/KinesisCollectorSpec.scala

@@ -63,7 +63,7 @@ class KinesisCollectorSpec extends Specification with Localstack with CatsEffect
             Collector.maxBytes
           )
           _ <- log(testName, "Data sent. Waiting for collector to work")
-          _ <- IO.sleep(5.second)
+          _ <- IO.sleep(30.second)
           _ <- log(testName, "Consuming collector's output")
           collectorOutput <- Kinesis.readOutput(streamGood, streamBad)
           _ <- printBadRows(testName, collectorOutput.bad)