Clean up terminated shards before expiry (close #222)

istreeter · istreeter · commit d64eae31ce3f · 2021-12-24T10:03:59.000Z
diff --git a/core/src/main/scala/com.snowplowanalytics.stream/loader/executors/KinesisSourceExecutor.scala b/core/src/main/scala/com.snowplowanalytics.stream/loader/executors/KinesisSourceExecutor.scala
@@ -75,7 +75,9 @@ class KinesisSourceExecutor[A, B](
       .withCallProcessRecordsEvenForEmptyRecordList(
         KinesisConnectorConfiguration.DEFAULT_CALL_PROCESS_RECORDS_EVEN_FOR_EMPTY_LIST
       )
-      .withCleanupLeasesUponShardCompletion(kcc.CLEANUP_TERMINATED_SHARDS_BEFORE_EXPIRY)
+      .withCleanupLeasesUponShardCompletion(
+        KinesisClientLibConfiguration.DEFAULT_CLEANUP_LEASES_UPON_SHARDS_COMPLETION
+      )
       .withParentShardPollIntervalMillis(kcc.PARENT_SHARD_POLL_INTERVAL)
       .withShardSyncIntervalMillis(kcc.SHARD_SYNC_INTERVAL)
       .withTaskBackoffTimeMillis(kcc.BACKOFF_INTERVAL)
