.build();
// make a set of the expected records with the new schema
Set<GenericRecord> expectedAsUpdated = Sets.newHashSet();
for (GenericRecord record : expected) {
expectedAsUpdated.add(updatedBuilder
.clear("priority")
.set("id", record.get("id"))
.set("msg", record.get("msg"))
.build());
}