redis: use expliciti initial stream ID based on the time of server start

diff --git a/src/knot/server/server.c b/src/knot/server/server.c
index 8b24918c116179561ce2e3c3f32362e5b1a80f5b..cedb88b3adf191bc2318cdefdd28bf9f28de0355 100644 (file)
--- 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) {