public static DynamicSchema parseFrom(InputStream schemaDescIn)
        throws Descriptors.DescriptorValidationException, IOException {
        try {
            int len;
            byte[] buf = new byte[4096];
            ByteArrayOutputStream baos = new ByteArrayOutputStream();
            while ((len = schemaDescIn.read(buf)) > 0) {
                baos.write(buf, 0, len);
            }
            return parseFrom(baos.toByteArray());
        } finally {
            schemaDescIn.close();
        }
    }
Parses a serialized schema descriptor (from input stream; closes the stream)

@param schemaDescIn the descriptor input stream
@return the schema object
core/src/main/java/kafka/automq/table/deserializer/proto/schema/DynamicSchema.java