File tree Expand file tree Collapse file tree
modules/eventbridge/src/it/scala/com/snowplowanalytics/snowplow/enrich/kinesis Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -128,9 +128,12 @@ object Source {
128128 InitialPositionInStreamExtended .newInitialPositionAtTimestamp(Date .from(timestamp))
129129 }
130130
131+ val leaseManagementConfig =
132+ configsBuilder.leaseManagementConfig
133+ .initialPositionInStream(initPositionExtended)
134+
131135 val retrievalConfig =
132136 configsBuilder.retrievalConfig
133- .initialPositionInStreamExtended(initPositionExtended)
134137 .retrievalSpecificConfig {
135138 kinesisConfig.retrievalMode match {
136139 case Input .Kinesis .Retrieval .FanOut =>
@@ -147,7 +150,7 @@ object Source {
147150 new Scheduler (
148151 configsBuilder.checkpointConfig,
149152 configsBuilder.coordinatorConfig,
150- configsBuilder. leaseManagementConfig,
153+ leaseManagementConfig,
151154 configsBuilder.lifecycleConfig,
152155 metricsConfig,
153156 configsBuilder.processorConfig,
You can’t perform that action at this time.
0 commit comments