@Test(expected = InvalidSchemaException.class)
public void registerSchema_incompatible() throws Exception {

  client.registerSchema("road1", schema1);
  client.registerSchema("road1", schema2);
  client.registerSchema("road1", schema3);
  client.registerSchema("road1", schema4);
}