apache-kafka - 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 设置为记录提交到数据库的时间。