Коллеги привет. У меня снова тупик в вопросе связки оракл-дебезиум-кафка-кликхаус.

Question

Коллеги привет. У меня снова тупик в вопросе связки оракл-дебезиум-кафка-кликхаус.

Данные в топике есть есть, таблицы в кликхаусе тоже. Но вот данные в топике я так понимаю не в том виде чтоб кликхаус их читал
Сейчас они идут по 2 json в строку первый начинается так {"schema":{"type":"struct","fields":[{"type":"int32","optional":false,"field":"EMPLOYEE_ID"}]
в конце второго в поле payload уже идут именно данные
,"payload":{"EMPLOYEE_ID":100,"FIRST_NAME":"Steven",
и я так понимаю чтобы кликхаус мог разбирать эти данные ему нужно передавать только значения из payload

я нашел вот такое видео https://www.youtube.com/watch?v=Te-eNQjEClE
здесь автор для решения этой задачи добавляет в конфиг параметры
"transforms": "unwrap",
"transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
и как видно из видео после этого в топике данные именно в таком виде стают, но вот у меня что-то это не срабатывает.

В итоге вопрос, как сделать чтобы данные были в нужном виде?