private int getLagLevel(long lagValue) {
        return (lagValue > TServerConstants.CFG_OFFSET_RESET_MID_ALARM_CHECK)
                ? 2
                : (lagValue > TServerConstants.CFG_OFFSET_RESET_MIN_ALARM_CHECK) ? 1 : 0;
    }
Load or create offset.

@param group            the consume group name
@param topic            the consumed topic name
@param partitionId      the consumed partition id
@param offsetCacheKey   the offset store key
@param defOffset        the default offset if not found
@return                 the stored offset object
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/DefaultOffsetManager.java