public void addSimpleEvent(SimpleEvent event) {
        Map<String, String> headers = event.getHeaders();
        String inlongGroupId = headers.get(AttributeConstants.GROUP_ID);
        String inlongStreamId = headers.get(AttributeConstants.STREAM_ID);
        String uid = InlongId.generateUid(inlongGroupId, inlongStreamId);
        long msgTime = NumberUtils.toLong(headers.get(AttributeConstants.DATA_TIME), System.currentTimeMillis());
        long dispatchTime = msgTime - msgTime % MINUTE_MS;
        SimplePackProfile profile = new SimplePackProfile(uid, inlongGroupId, inlongStreamId, dispatchTime);
        profile.addEvent(event, maxPackCount, maxPackSize);
        this.mqZoneSink.acquireAndOfferDispatchedRecord(profile);
        this.outCounter.addAndGet(profile.getCount());
        this.inCounter.incrementAndGet();
    }
addSimpleEvent
@param event  the event need to add
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/BatchPackManager.java