Extend default timeouts

snowplow · Aug 20, 2024 · f2566b4 · f2566b4
1 parent 6a68947
commit f2566b4
Show file tree

Hide file tree

Showing 6 changed files with 13 additions and 12 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/...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
     ),