Remove warning for concurrency.sink (close #896)

snowplow · May 17, 2024 · b79dd2d · b79dd2d
1 parent 54e1a97
commit b79dd2d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/config/config.kafka.extended.hocon b/config/config.kafka.extended.hocon
@@ -96,8 +96,7 @@
     # Number of events that can get enriched at the same time within a chunk
     "enrich": 256
     # Number of chunks that can get sunk at the same time
-    # WARNING: if greater than 1, records can get checkpointed before they are sunk
-    "sink": 1
+    "sink": 256
   }
 
   # Optional, period after which enrich assets should be checked for updates

diff --git a/config/config.kinesis.extended.hocon b/config/config.kinesis.extended.hocon
@@ -221,8 +221,7 @@
     # Number of events that can get enriched at the same time within a chunk
     "enrich": 256
     # Number of chunks that can get sunk at the same time
-    # WARNING: if greater than 1, records can get checkpointed before they are sunk
-    "sink": 1
+    "sink": 256
   }
 
   # Optional, period after which enrich assets should be checked for updates