Примените трансформатор к столбцам струн, чтобы выполнить обрезку в источнике debezium - PullRequest
0 голосов
/ 08 мая 2020

У меня есть исходная база данных, в которой поля заполняются пробелами, пока не достигнут размер поля. Например, если у нас есть таблица с VARCHAR(20), если я получу эту информацию, результатом будет каждый раз размер 20 вместо фактического значения поля, мне не нужен полный размер.

В качестве примера: если мы поместим строку с размером 5, устаревшая система добавит площадку с пробелами в конце, заставляя поле достигать максимального размера столбца.

Моя исходная база данных - это SQL сервер, и я использую Kafka и debezium в качестве исходного соединителя, чтобы получить изменения CD C и поместить их в соединитель приемника, то есть в PostgreSQL.

Существует что-то, что можно применить в качестве преобразователя, чтобы изменить только строки для выполнения trim() и сохранить мои topi c без этих лишних пробелов?

Преобразование необходимо выполнить в Кафка. Я не могу изменить источник, потому что это система стороннего производителя, поэтому преобразование должно выполняться с помощью преобразователей или соединителей.

...