Enable KCL option skipShardSyncAtWorkerInitializationIfLeasesExist

snowplow-incubator · Sep 8, 2024 · f890152 · f890152
1 parent fecae1b
commit f890152
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...kinesis/src/main/scala/com/snowplowanalytics/snowplow/sources/kinesis/KinesisSource.scala b/...kinesis/src/main/scala/com/snowplowanalytics/snowplow/sources/kinesis/KinesisSource.scala
@@ -202,9 +202,13 @@ object KinesisSource {
         configsBuilder.processorConfig
           .callProcessRecordsEvenForEmptyRecordList(true)
 
+      val coordinatorConfig =
+        configsBuilder.coordinatorConfig
+          .skipShardSyncAtWorkerInitializationIfLeasesExist(true)
+
       new Scheduler(
         configsBuilder.checkpointConfig,
-        configsBuilder.coordinatorConfig,
+        coordinatorConfig,
         leaseManagementConfig,
         configsBuilder.lifecycleConfig,
         configsBuilder.metricsConfig.metricsLevel(MetricsLevel.NONE),