@Override
    public boolean brokerHeartBeat2M(int brokerId, long reportConfigId, int reportCheckSumId,
            boolean isTackData, String repBrokerConfInfo,
            List<String> repTopicConfInfo,
            boolean isTackRmvInfo, List<String> removedTopics,
            int rptReadStatus, int rptWriteStatus, boolean isOnline,
            StringBuilder sBuffer, ProcessResult result) {
        BrokerRunStatusInfo runStatusInfo =
                brokerRunSyncManageMap.get(brokerId);
        if (runStatusInfo == null) {
            result.setFailResult(TErrCodeConstants.HB_NO_NODE, sBuffer
                    .append("Not found Broker run status info, please register broker first!")
                    .append(" the connecting client id is:").append(brokerId).toString());
            return result.isSuccess();
        }
        // update heartbeat
        if (!heartbeatManager.updBrokerNode(String.valueOf(brokerId),
                runStatusInfo.getCreateId(), sBuffer, result)) {
            return result.isSuccess();
        }
        // update broker status
        runStatusInfo.bookBrokerReportInfo(false, isOnline, reportConfigId,
                reportCheckSumId, isTackData, repBrokerConfInfo, repTopicConfInfo, sBuffer);
        // process removed topic info
        if (isTackRmvInfo) {
            metaDataService.delCleanedTopicDeployInfo(brokerId, removedTopics, sBuffer, result);
            logger.info(sBuffer.append("[Broker Report] brokerId=").append(brokerId)
                    .append(" removed topics = ").append(removedTopics)
                    .append(", removed result is ").append(result.getErrMsg()).toString());
            sBuffer.delete(0, sBuffer.length());
        }
        brokerAbnHolder.updateBrokerReportStatus(brokerId, rptReadStatus, rptWriteStatus);
        result.setSuccResult(null);
        return result.isSuccess();
    }
Constructor by TMaster

@param tMaster  the initial TMaster object
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/nodemanage/nodebroker/DefBrokerRunManager.java