Extend default timeouts to match upstream defaults

The reference defaults should be less strict and match the settings we define upstream.
snowplow · Aug 21, 2024 · 689a96f · 689a96f
1 parent 6a68947
commit 689a96f
Show file tree

Hide file tree

Showing 7 changed files with 15 additions and 14 deletions.
diff --git a/core/src/main/resources/reference.conf b/core/src/main/resources/reference.conf
@@ -94,10 +94,11 @@
   networking {
     maxConnections = 1024
     idleTimeout = 610 seconds
-    responseHeaderTimeout = 5 seconds
-    bodyReadTimeout = 1 second
+    responseHeaderTimeout = 30 seconds
+    bodyReadTimeout = 28 seconds
     maxRequestLineLength = 20480
     maxHeadersLength = 40960
+    maxPayloadSize = 1048576 # 1MB
   }
 
   debug {

diff --git a/core/src/test/scala/com.snowplowanalytics.snowplow.collector.core/TestUtils.scala b/core/src/test/scala/com.snowplowanalytics.snowplow.collector.core/TestUtils.scala
@@ -120,8 +120,8 @@ object TestUtils {
     networking = Networking(
       1024,
       610.seconds,
-      5.seconds,
-      1.second,
+      30.seconds,
+      28.second,
       20480,
       40960
     ),

diff --git a/...rc/test/scala/com.snowplowanalytics.snowplow.collectors.scalastream/KafkaConfigSpec.scala b/...rc/test/scala/com.snowplowanalytics.snowplow.collectors.scalastream/KafkaConfigSpec.scala
@@ -171,8 +171,8 @@ object KafkaConfigSpec {
     networking = Config.Networking(
       maxConnections        = 1024,
       idleTimeout           = 610.seconds,
-      responseHeaderTimeout = 5.seconds,
-      bodyReadTimeout       = 1.second,
+      responseHeaderTimeout = 30.seconds,
+      bodyReadTimeout       = 28.seconds,
       maxRequestLineLength  = 20480,
       maxHeadersLength      = 40960
     ),

diff --git a/...scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/KinesisConfigSpec.scala b/...scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/KinesisConfigSpec.scala
@@ -125,8 +125,8 @@ object KinesisConfigSpec {
     networking = Config.Networking(
       maxConnections        = 1024,
       idleTimeout           = 610.seconds,
-      responseHeaderTimeout = 5.seconds,
-      bodyReadTimeout       = 1.second,
+      responseHeaderTimeout = 30.seconds,
+      bodyReadTimeout       = 28.seconds,
       maxRequestLineLength  = 20480,
       maxHeadersLength      = 40960
     ),

diff --git a/nsq/src/test/scala/com.snowplowanalytics.snowplow.collectors.scalastream/NsqConfigSpec.scala b/nsq/src/test/scala/com.snowplowanalytics.snowplow.collectors.scalastream/NsqConfigSpec.scala
@@ -158,8 +158,8 @@ object NsqConfigSpec {
     networking = Config.Networking(
       maxConnections        = 1024,
       idleTimeout           = 610.seconds,
-      responseHeaderTimeout = 5.seconds,
-      bodyReadTimeout       = 1.second,
+      responseHeaderTimeout = 30.seconds,
+      bodyReadTimeout       = 28.seconds,
       maxRequestLineLength  = 20480,
       maxHeadersLength      = 40960
     ),

diff --git a/pubsub/src/test/scala/com.snowplowanalytics.snowplow.collectors.scalastream/ConfigSpec.scala b/pubsub/src/test/scala/com.snowplowanalytics.snowplow.collectors.scalastream/ConfigSpec.scala
@@ -114,8 +114,8 @@ object ConfigSpec {
     networking = Config.Networking(
       maxConnections        = 1024,
       idleTimeout           = 610.seconds,
-      responseHeaderTimeout = 5.seconds,
-      bodyReadTimeout       = 1.second,
+      responseHeaderTimeout = 30.seconds,
+      bodyReadTimeout       = 28.seconds,
       maxRequestLineLength  = 20480,
       maxHeadersLength      = 40960
     ),

diff --git a/sqs/src/test/scala/com.snowplowanalytics.snowplow.collectors.scalastream/SqsConfigSpec.scala b/sqs/src/test/scala/com.snowplowanalytics.snowplow.collectors.scalastream/SqsConfigSpec.scala
@@ -115,8 +115,8 @@ object SqsConfigSpec {
     networking = Config.Networking(
       maxConnections        = 1024,
       idleTimeout           = 610.seconds,
-      responseHeaderTimeout = 5.seconds,
-      bodyReadTimeout       = 1.second,
+      responseHeaderTimeout = 30.seconds,
+      bodyReadTimeout       = 28.seconds,
       maxRequestLineLength  = 20480,
       maxHeadersLength      = 40960
     ),