diff --git a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go index 08da7c978e..706d7fdc66 100644 --- a/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go +++ b/internal/util/rocksmq/server/rocksmq/rocksmq_impl.go @@ -874,7 +874,7 @@ func (rmq *rocksmq) updateAckedInfo(topicName, groupName string, ids []UniqueID) iter := rmq.kv.(*rocksdbkv.RocksdbKV).DB.NewIterator(readOpts) defer iter.Close() - pageIDs := make([]UniqueID, 0) + var pageIDs []UniqueID pageMsgKey := pageMsgPrefix + "/" + strconv.FormatInt(firstID, 10) for iter.Seek([]byte(pageMsgKey)); iter.Valid(); iter.Next() { key := iter.Key()