Debezium Kafka 连接。十进制模式错误

Debezium Kafka connect. Decimal schema error

我正在使用 PostgreSQL。 在我的 table 数字列中定义如下:

"net_weight" numeric(19,2)

但在 Kafka 中,我收到的不是十进制数字(例如 14.0),而是 "E4g="

版本: debezium/connect:0.7 卡夫卡 0.11.0.0 动物园管理员 3.4.9

有人知道如何解决这个问题吗?

NUMERIC 列可以编码为 BigDecimal 二进制值(您现在看到的),doublestring。请参阅 decimal.handling.mode 配置选项。 您需要将值解码回来 - https://debezium.io/docs/faq/#how_to_retrieve_decimal_field_from_binary_representation 或者您可以使用其他格式。当心 double 你可能会失去精度。