1. 程式人生 > >Debezium:資料型別numeric、decimal由PostgreSql輸出到kafka後型別不匹配問題

Debezium:資料型別numeric、decimal由PostgreSql輸出到kafka後型別不匹配問題

環境:

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型別

官網:

修改為string後,輸出結果為:

輸出正常資料