@Override
                        public IndexRepairStore call() throws Exception {
                            StringBuilder sBuilder = new StringBuilder(512);
                            logger.info(sBuilder.append("[Data Repair] Loading data directory:")
                                    .append(subDir.getAbsolutePath()).append("...").toString());
                            sBuilder.delete(0, sBuilder.length());
                            final IndexRepairStore messageStore =
                                    new IndexRepairStore(storePath, topic, storeId);
                            messageStore.reCreateIndexFiles();
                            logger.info(sBuilder.append("[Data Repair] Finished data index recreation :")
                                    .append(subDir.getAbsolutePath()).toString());
                            return messageStore;
                        }
Repair topic storage files, rebuild index files by existing data files
@param args   Startup parameter array, including the following parts:
              The 1st parameter is the path of topic storage files;
              The 2nd parameter is the topic name(s) that needs to be repaired,
                  if not specified, all topics in the storage path will be repaired.
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/StoreRepairAdmin.java