public static List<ProxyEvent> decodeSdkPack(MessagePack packObject) throws IOException {
        MessagePackHeader header = packObject.getHeader();
        // decompress
        byte[] compressBytes = packObject.getCompressBytes().toByteArray();
        byte[] srcBytes = null;
        switch (header.getCompressType()) {
            case INLONG_SNAPPY:
                srcBytes = Snappy.uncompress(compressBytes);
                break;
            case INLONG_GZ:
                srcBytes = GzipUtils.decompress(compressBytes);
                break;
            case INLONG_NO_COMPRESS:
            default:
                srcBytes = compressBytes;
                break;
        }
        // decode
        MessageObjs msgObjs = MessageObjs.parseFrom(srcBytes);
        List<ProxyEvent> events = new ArrayList<>(msgObjs.getMsgsList().size());
        String inlongGroupId = header.getInlongGroupId();
        String inlongStreamId = header.getInlongStreamId();
        for (MessageObj msgObj : msgObjs.getMsgsList()) {
            ProxyEvent event = new ProxyEvent(inlongGroupId, inlongStreamId, msgObj);
            events.add(event);
        }
        return events;
    }
decodeSdkPack

@param  packObject
@return List,ProxyEvent
@throws IOException
inlong-sdk/sdk-common/src/main/java/org/apache/inlong/sdk/commons/protocol/EventUtils.java