-
Bug
-
Resolution: Done
-
Minor
-
1.6.0.Final, 1.7.0.Final, 1.8.0.Alpha1
-
False
-
False
-
-
Affect from 1.6 to 1.8
public class ConvertingEngineBuilder<R> implements Builder<R> { @SuppressWarnings("unchecked") @Override public DebeziumEngine<R> build() { . . . keyConverter = createConverter(formatKey, true); valueConverter = createConverter(formatValue, false); toFormat = (record) -> { final byte[] key = keyConverter.fromConnectData(TOPIC_NAME, record.keySchema(), record.key()); final byte[] value = valueConverter.fromConnectData(TOPIC_NAME, record.valueSchema(), record.value()); // Here the 'value' and record.value() has accents return isFormat(formatKey, Json.class) && isFormat(formatValue, Json.class) || isFormat(formatValue, CloudEvents.class) // Here, with "new String(value)" you are loosing accents // You can check the bytes between "byte[] value" & "new String(value) bytes" // You can replace by "new String(value, StandardCharsets.UTF_8)" to fix it ? (R) new EmbeddedEngineChangeEvent<String, String>( key != null ? new String(key) : null, value != null ? new String(value) : null, record) : (R) new EmbeddedEngineChangeEvent<byte[], byte[]>( key, value, record); };