Debezium:数据类型numeric、decimal由PostgreSql输出到kafka后类型不匹配问题

时间:2024-04-06 12:29:36

环境:

Debezium版本:0.8.3

PostgreSql版本:9.5

Kafka版本:CDK3.1.0(KAFKA:1.0.1)


问题:Debezium从postgresql解析数据到kafka后,发现numeric类型数据输出格式异常,如下:

{"scale":0,"value":"F3A="}

Debezium:数据类型numeric、decimal由PostgreSql输出到kafka后类型不匹配问题

原值为6000

解决:需要配置参数,更新kafka连接器配置

"decimal.handling.mode": "string"

备注:这里配置默认值为precise,我们可以修改为:double、string,这个参数适用于decimal、numeric类型

double:

设置成double后,输出结果为java的double类型

string:

设置成string后,输出结果为string类型

官网:

https://debezium.io/docs/connectors/postgresql/

Debezium:数据类型numeric、decimal由PostgreSql输出到kafka后类型不匹配问题

修改为string后,输出结果为:

Debezium:数据类型numeric、decimal由PostgreSql输出到kafka后类型不匹配问题

输出正常数据