public static InLongMsg newInLongMsg(int capacity, boolean compress) {
        return new InLongMsg(capacity, compress, Version.v1);
    }
version: 1

@param capacity data capacity
@param compress if compress
@return InLongMsg
inlong-common/src/main/java/org/apache/inlong/common/msg/InLongMsg.java