reversed history fix for meta keys with epoch only

centrifugal · Nov 2, 2023 · 61992de · 61992de
1 parent 1baf9f6
commit 61992de
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/internal/redis_lua/broker_history_list.lua b/internal/redis_lua/broker_history_list.lua
@@ -14,6 +14,10 @@ if current_epoch == false then
   redis.call("hset", meta_key, "e", current_epoch, "s", "0")
 end
 
+if top_offset == false then
+  top_offset = 0
+end
+
 if meta_expire ~= '0' then
   redis.call("expire", meta_key, meta_expire)
 end

diff --git a/internal/redis_lua/broker_history_stream.lua b/internal/redis_lua/broker_history_stream.lua
@@ -16,6 +16,10 @@ if current_epoch == false then
   redis.call("hset", meta_key, "e", current_epoch, "s", "0")
 end
 
+if top_offset == false then
+  top_offset = 0
+end
+
 if meta_expire ~= '0' then
   redis.call("expire", meta_key, meta_expire)
 end