环境:
Debezium版本:0.8.3
PostgreSql版本:9.5
Kafka版本:CDK3.1.0(KAFKA:1.0.1)
问题:Debezium从postgresql解析数据到kafka后,发现numeric类型数据输出格式异常,如下:
{"scale":0,"value":"F3A="}
原值为6000
解决:需要配置参数,更新kafka连接器配置
"decimal.handling.mode": "string"
备注:这里配置默认值为precise,我们可以修改为:double、string,这个参数适用于decimal、numeric类型
double:
设置成double后,输出结果为java的double类型
string:
设置成string后,输出结果为string类型
官网:
https://debezium.io/docs/connectors/postgresql/
修改为string后,输出结果为:
输出正常数据