@Test
public void registerSchema_specifyVersion() throws Exception {

  SchemaVersion registerSchema = client.registerSchema("road1", schema2, 2);
  assertThat(registerSchema, is(schemaVersion2));
  Map<Integer, SchemaVersion> schemas = store.get("road1").getSchemas();
  assertThat(schemas.size(), is(1));
  assertThat(schemas.get(2), is(schemaVersion2));
}