@Test
@FixFor({ "DBZ-1452", "DBZ-2504" })

public void testAddFields() {
    try (final ExtractNewRecordState<SourceRecord> transform = new ExtractNewRecordState<>()) {
        final Map<String, String> props = new HashMap<>();
        props.put(ADD_FIELDS, "op , lsn,id");
        props.put(ADD_FIELDS_PREFIX, "prefix.");
        transform.configure(props);
        final SourceRecord updateRecord = createUpdateRecord();
        final SourceRecord unwrapped = transform.apply(updateRecord);
        assertThat(((Struct) unwrapped.value()).get("prefix.op")).isEqualTo(Envelope.Operation.UPDATE.code());
        assertThat(((Struct) unwrapped.value()).get("prefix.lsn")).isEqualTo(1234);
        assertThat(((Struct) unwrapped.value()).get("prefix.id")).isEqualTo("571");
    }
}