Я сталкиваюсь с проблемой, когда схема моей таблицы похожа на эту
requested_price numeric(24, 8),
executed_price numeric(24, 8),
old_executed_price numeric(24, 8)
и из-за приведенного ниже кода
https://github.com/confluentinc/kafka-connect-jdbc/blob/3c19049fdf9af562b58efca5bfefbb31ba2801f5/src/main/java/io/confluent/connect/jdbc/dialect/GenericDatabaseDialect.java#L1157
itзакрывает тип на удвоение, так как масштаб больше 0, и json-конвертер анализирует его в виде
"requested_price": "IwzS2MA=",
"executed_price": "IwylEgA=",
"old_executed_price": "IwzS2MA="
. В качестве строкового конвертера он дает мне точные двойные числа.У любого есть предложение получить данные в правильном формате.
Я пробовал что-то подобное
numeric.mapping=precision_only
numeric.precision.mapping=true
в моем файле свойств коннектора, но, к сожалению, безрезультатно.
Одно из решений, которое я думаю, заключается в том, что когда я получаю данные в правильном формате с помощью конвертера строк, я могу использовать конвертер строк и выгружать данные в теме, а при использовании записи у меня может быть свой собственный десериализатор, который обрабатывает строку и возвращает данные вправильный формат.