@Test
@FixFor("DBZ-1044")
public void shouldSanitizeFieldNamesAndValidateSerialization() {

    schema = new TableSchemaBuilder(new JdbcValueConverters(), adjuster, customConverterRegistry, SchemaBuilder.struct().build(), true)
            .create(prefix, "sometopic", table, null, null, null);
    Struct key = (Struct) schema.keyFromColumnData(keyData);
    Struct value = schema.valueFromColumnData(data);
    SourceRecord record = new SourceRecord(Collections.emptyMap(), Collections.emptyMap(), "sometopic", schema.keySchema(), key, schema.valueSchema(), value);
    VerifyRecord.isValid(record);
}