@Override
    public boolean addEvent(Event event, long maxPackCount, long maxPackSize) {
        setCount(1);
        setSize(event.getBody().length);
        if (event instanceof SinkRspEvent) {
            SinkRspEvent rspEvent = (SinkRspEvent) event;
            this.needRspEvent = true;
            this.event = rspEvent.getEvent();
            this.channel = rspEvent.getChannel();
            this.msgType = rspEvent.getMsgType();
        } else {
            this.event = event;
            this.needRspEvent = false;
        }
        return true;
    }
Constructor
@param uid   the inlong id
@param inlongGroupId   the group id
@param inlongStreamId  the stream id
@param dispatchTime    the received time
inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/SimplePackProfile.java