Здраствуйте Максим. Спасибо за видео, очень помогло в аналогичной настройке с ораклом. Но возник вопрос. Вы используете трансформацию "transforms" : "unwrap", "transforms.unwrap.type" : "io.debezium.transforms.ExtractNewRecordState". В документации к дебезиумум описано что таким образом состояние before опускается, а состояние after пишет. Так собственно и происходит. Но вот в вашем видео схема json упрощается куда больше - если раньше json состояли из двух полей schema и payload, то теперь берется лишь значение payload. Как вы это сделали? В вашем конфиге не видно каких то еще трансоформаций
на всякий случай, если вдруг кто станет искать. Решается через использование key.converter=org.apache.kafka.connect.json.JsonConverter value.converter=org.apache.kafka.connect.json.JsonConverter key.converter.schemas.enable=false value.converter.schemas.enable=false
