diff --git a/airbyte-workers/src/main/java/io/airbyte/workers/helpers/ScheduleJitterHelper.java b/airbyte-workers/src/main/java/io/airbyte/workers/helpers/ScheduleJitterHelper.java index 353b26ab61d..3ebb4f15e5e 100644 --- a/airbyte-workers/src/main/java/io/airbyte/workers/helpers/ScheduleJitterHelper.java +++ b/airbyte-workers/src/main/java/io/airbyte/workers/helpers/ScheduleJitterHelper.java @@ -7,6 +7,7 @@ import io.airbyte.api.client.model.generated.ConnectionScheduleType; import io.micronaut.context.annotation.Value; import jakarta.inject.Singleton; +import java.security.SecureRandom; import java.time.Duration; import java.util.Random; import lombok.extern.slf4j.Slf4j; @@ -62,7 +63,7 @@ public Duration addJitterBasedOnWaitTime(final Duration waitTime, final Connecti } final int jitterSeconds; - final Random random = new Random(); + final Random random = new SecureRandom(); // CRON schedules should not have negative jitter included, because then it is possible for the sync // to start and finish before the real scheduled time. This can result in a double sync because the