debezium 日期/时间字段值超出范围：0000-12-30T00:00:00Z

Question

我们使用 Debezium 将数据同步到 在源表中我们有列timestamptz

start_at

，当值为零时

start_at='0001-01-01 00:00:00.000000 +00:00'

，但是当我们检查kafka中的数据时，它变成了

start_at = '0000-12-30T00:00:00Z'

。当我们使用jdbc接收器连接器写入另一个postgres数据库时，它会导致错误

ERROR: date/time field value out of range: "0000-12-30T00:00:00Z"

这是我的关于 time.precesion.mode 的 debezium 配置

    "time.precision.mode": "connect",
    "decimal.handling.mode": "double",

是否有任何解决方案可以在 kafka 上设置数据匹配 postgres 中的零时间戳值？

Answer 1

我认为你的情况的根本原因是时区转换器。当您在时间戳列中应用时区时，Debezium 会转换为另一个时区，从而导致上述错误。

以一种简单的方式，您可以在其他时间初始化时间戳值（例如：03-01-0001, 01-03-0001, ...）

希望可以帮到你