public static long getAuditVersion(Map<String, String> headers) {
        String strAuditVersion = headers.get(AttributeConstants.AUDIT_VERSION);
        if (StringUtils.isNotBlank(strAuditVersion)) {
            try {
                return Long.parseLong(strAuditVersion);
            } catch (Throwable ex) {
                //
            }
        }
        return -1L;
    }
Get Audit version

@param headers  the message headers

@return audit version
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/metrics/audit/AuditUtils.java