public void updSubRepInfo(BrokerRunManager brokerRunManager,
            ClientMaster.ClientSubRepInfo clientSubRepInfo) {
        if (clientSubRepInfo == null) {
            return;
        }
        if (clientSubRepInfo.hasBrokerConfigId()) {
            this.brokerConfigId = clientSubRepInfo.getBrokerConfigId();
            this.updated = true;
        }
        if (clientSubRepInfo.hasTopicMetaInfoId()) {
            this.topicMetaInfoId = clientSubRepInfo.getTopicMetaInfoId();
            this.updated = true;
        }
        if (clientSubRepInfo.hasLstAssignedTime()) {
            this.lstAssignedTime = clientSubRepInfo.getLstAssignedTime();
            this.updated = true;
        }
        if (clientSubRepInfo.hasReportSubInfo()) {
            this.repPartInfo = clientSubRepInfo.getReportSubInfo();
            if (this.repPartInfo) {
                for (String info : clientSubRepInfo.getPartSubInfoList()) {
                    if (TStringUtils.isBlank(info)) {
                        continue;
                    }
                    String[] strInfo = info.split(TokenConstants.SEGMENT_SEP);
                    String[] strPartInfoSet = strInfo[1].split(TokenConstants.ARRAY_SEP);
                    for (String partStr : strPartInfoSet) {
                        String[] strPartInfo = partStr.split(TokenConstants.ATTR_SEP);
                        BrokerInfo brokerInfo =
                                brokerRunManager.getBrokerInfo(Integer.parseInt(strPartInfo[0]));
                        if (brokerInfo == null) {
                            continue;
                        }
                        subPartSet.add(new Partition(brokerInfo,
                                strInfo[0], Integer.parseInt(strPartInfo[1])));
                    }
                }
            }
            this.updated = true;
        }
    }
Update the client reported subscription information

@param brokerRunManager   the broker run-manager
@param clientSubRepInfo   the client reported subscription information
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/utils/ClientSyncInfo.java