private static void addAuditData(Event event, int auditID) {
        Map<String, String> headers = event.getHeaders();
        String pkgVersion = headers.get(ConfigConstants.MSG_ENCODE_VER);
        if (MessageWrapType.INLONG_MSG_V1.getStrId().equalsIgnoreCase(pkgVersion)) {
            String inlongGroupId = DataProxyMetricItem.getInlongGroupId(headers);
            String inlongStreamId = DataProxyMetricItem.getInlongStreamId(headers);
            long logTime = getLogTime(headers);
            long msgCount = 1L;
            if (event.getHeaders().containsKey(ConfigConstants.MSG_COUNTER_KEY)) {
                msgCount = Long.parseLong(event.getHeaders().get(ConfigConstants.MSG_COUNTER_KEY));
            }
            long auditVersion = getAuditVersion(headers);
            AuditOperator.getInstance().add(auditID, DEFAULT_AUDIT_TAG,
                    inlongGroupId, inlongStreamId, logTime, msgCount, event.getBody().length, auditVersion);
        } else {
            String groupId = headers.get(AttributeConstants.GROUP_ID);
            String streamId = headers.get(AttributeConstants.STREAM_ID);
            long dataTime = NumberUtils.toLong(headers.get(AttributeConstants.DATA_TIME));
            long msgCount = NumberUtils.toLong(headers.get(ConfigConstants.MSG_COUNTER_KEY));
            long auditVersion = getAuditVersion(headers);
            AuditOperator.getInstance().add(auditID, DEFAULT_AUDIT_TAG,
                    groupId, streamId, dataTime, msgCount, event.getBody().length, auditVersion);
        }
    }
Add output audit data

@param event    event to be counted
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/metrics/audit/AuditUtils.java