From 847d3e7d4a0a785f95894c6173ecd16482d69d96 Mon Sep 17 00:00:00 2001
From: yukun <kun.yu@zilliz.com>
Date: Mon, 6 Dec 2021 15:17:35 +0800
Subject: [PATCH] Break page loop when no acked ts is nil (#12705)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
---
 internal/util/rocksmq/server/rocksmq/rocksmq_retention.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
index 70fc95e43c..58e704eaa1 100644
--- a/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
+++ b/internal/util/rocksmq/server/rocksmq/rocksmq_retention.go
@@ -171,6 +171,9 @@ func (ri *retentionInfo) expiredCleanUp(topic string) error {
 			if err != nil {
 				return err
 			}
+			if ackedTsVal == "" {
+				break
+			}
 			ackedTs, err := strconv.ParseInt(ackedTsVal, 10, 64)
 			if err != nil {
 				return err