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