From 3877f3c40f4540cf5304a8bac003e39b778dec3e Mon Sep 17 00:00:00 2001 From: Daniel Salzman Date: Wed, 26 Nov 2025 13:09:37 +0100 Subject: [PATCH] redis: use expliciti initial stream ID based on the time of server start --- src/knot/server/server.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/knot/server/server.c b/src/knot/server/server.c index 8b24918c11..cedb88b3ad 100644 --- a/src/knot/server/server.c +++ b/src/knot/server/server.c @@ -938,7 +938,10 @@ static int rdb_listener_run(struct dthread *thread) server_t *s = thread->data; s->rdb_ctx = NULL; + + const uint64_t prop_delay = 60; // Maximum considered propagation delay to all replicas. char since[RDB_TIMESTAMP_SIZE] = "$"; + (void)snprintf(since, sizeof(since), "%"PRIu64"-0", (knot_time() - prop_delay) * 1000); while (thread->state & ThreadActive) { if (s->rdb_ctx == NULL) { -- 2.47.3