@Test
@FixFor("DBZ-1015")
public void shouldOverrideIdentityKey() {

    schema = new TableSchemaBuilder(new JdbcValueConverters(), adjuster, customConverterRegistry, SchemaBuilder.struct().build(), false)
            .create(prefix, "sometopic", table, null, null, CustomKeyMapper.getInstance("(.*).table:C2,C3", null));
    assertThat(schema).isNotNull();
    Schema keys = schema.keySchema();
    assertThat(keys).isNotNull();
    assertThat(keys.fields()).hasSize(2);
    assertThat(keys.field("C1")).isNull();
    assertThat(keys.field("C2").name()).isEqualTo("C2");
    assertThat(keys.field("C3").name()).isEqualTo("C3");
}