我使用 debizium 將 postgresql 數據流式傳輸到 Kafka，并使用 Java 訂閱 Kafka 主題。我收到 Kafka 消息并得到一個 JSON 字符串，但無法識別一個數值。JSON 是：{ "schema": { "type": "struct", "fields": [ { "type": "struct", "fields": [ { "type": "string", "optional": true, "field": "creator" }, { "type": "int64", "optional": true, "name": "io.debezium.time.MicroTimestamp", "version": 1, "field": "createtime" }, { "type": "bytes", "optional": true, "name": "org.apache.kafka.connect.data.Decimal", "version": 1, "parameters": { "scale": "5", "connect.decimal.precision": "32" }, "field": "familyprice" }], "optional": true, "name": "pssdev.public.order.Value", "field": "before" }, { "type": "struct", "fields": [ { "type": "string", "optional": true, "field": "creator" }, { "type": "int64", "optional": true, "name": "io.debezium.time.MicroTimestamp", "version": 1, "field": "createtime" },familyprice 值是W42A我不知道如何轉換它。familyprice在數據庫中的實際值為60.00000，列類型為numeric(32,5)
1 回答
大話西游666
TA貢獻1817條經驗 獲得超14個贊
請參閱https://debezium.io/documentation/faq/#how_to_retrieve_decimal_field_from_binary_representation Java 客戶端。
您還可以設置decimal.handling.mode為不同的值，這樣您就可以將小數作為字符串或雙精度接收，如果對您來說更容易的話。
添加回答
舉報
0/150
提交
取消