public void setLastProcInfo(long lastGetTime, long lastRdDataOffset, int totalMsgSize) {
        this.lastGetTime = lastGetTime;
        this.lastDataRdOffset = lastRdDataOffset;
        this.sentMsgSize += totalMsgSize;
        this.totalUnitMin += totalMsgSize;

    }
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