Debezium如何设置Kafka消息时间戳

Question

我没有找到任何关于 Debezium 如何设置 Kafka 消息时间戳以及是否设置的文档。

通过比较值，Kafka 消息时间戳始终落后于数据库表更改的时间戳 (source.ts_ms)，也落后于 Debezium 处理更改的时间 (ts_ms)。这表明 Kafka 消息时间戳只是 Kafka 代理设置为摄取时间的时间戳。

是否有人知道有关 Debezium 是否以及如何在其填充的接收器主题中设置 Kafka 消息时间戳的详细信息？

我正在使用适用于 SQL 服务器的 Debezium 连接器来解决这个问题。

Answer 1

值得检查source.timestamp.mode 参数。根据文档（之前喜欢），其默认值 commit 应将 ts_ms 设置为记录提交到数据库的时间。

Answer 2

Debezium 既没有设置 Kafka Connect 时间戳，也没有设置 Kafka 消息时间戳。前者留空，后者由 Kafka Connect 管理。