private boolean checkData(ByteBuffer data) {
        if ((version.intValue() == Version.v3.intValue()) && !ischeck) {
            return true;
        }

        // check data
        data.mark();
        int msgnum = 0;
        while (data.remaining() > 0) {
            int datalen = data.getInt();
            if (datalen > data.remaining()) {
                return false;
            }
            msgnum++;
            byte[] record = new byte[datalen];
            data.get(record, 0, datalen);
        }

        msgnum = msgnum / 2;
        if (msgnum > 1) {
            msgcnt += msgnum - 1;
        }
        data.reset();
        return true;
    }
add msg
@param attr
@param data
@return
inlong-common/src/main/java/org/apache/inlong/common/msg/InLongMsg.java