public static Schema getBeamSchemaFromProtoSchema(String schemaString, String messageName) {
    Descriptors.Descriptor descriptor = getDescriptorFromProtoSchema(schemaString, messageName);
    return ProtoDynamicMessageSchema.forDescriptor(ProtoDomain.buildFrom(descriptor), descriptor)
        .getSchema();
  }
@Test
  public void testProtoSchemaWitPackageStringToBeamSchema() {
    Schema schema =
        ProtoByteUtils.getBeamSchemaFromProtoSchema(
            PROTO_STRING_PACKAGE_SCHEMA, "com.test.proto.MyMessage");
    Assert.assertEquals(schema.getFieldNames(), SCHEMA.getFieldNames());
  }