У меня есть исходная база данных, в которой поля заполняются пробелами, пока не достигнут размер поля. Например, если у нас есть таблица с VARCHAR(20)
, если я получу эту информацию, результатом будет каждый раз размер 20
вместо фактического значения поля, мне не нужен полный размер.
В качестве примера: если мы поместим строку с размером 5, устаревшая система добавит площадку с пробелами в конце, заставляя поле достигать максимального размера столбца.
Моя исходная база данных - это SQL сервер, и я использую Kafka и debezium в качестве исходного соединителя, чтобы получить изменения CD C и поместить их в соединитель приемника, то есть в PostgreSQL.
Существует что-то, что можно применить в качестве преобразователя, чтобы изменить только строки для выполнения trim()
и сохранить мои topi c без этих лишних пробелов?
Преобразование необходимо выполнить в Кафка. Я не могу изменить источник, потому что это система стороннего производителя, поэтому преобразование должно выполняться с помощью преобразователей или соединителей.