public void setConsumerId(String consumerId) {
        this.consumerId = consumerId;
        if (consumerId.lastIndexOf("_") != -1) {
            String targetStr = consumerId.substring(consumerId.lastIndexOf("_") + 1);
            String[] strInfos = targetStr.split("-");
            if (strInfos.length > 2) {
                this.rmtAddrInfo = new StringBuilder(256)
                        .append(strInfos[0]).append("#").append(strInfos[1]).toString();
            }
        }
    }
Query the current allowed maximum consumption size

@param storeKey              the store block key
@param flowCtrlRuleHandler   the flow-control rule handler
@param currMaxDataOffset     the current max data offset
@param maxMsgTransferSize    the max message transfer size
@param isEscFlowCtrl         whether need escape flow-control process
@return                      the allowed consumption size
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/nodeinfo/ConsumerNodeInfo.java