Debezium系列之:时区转换器,时间戳字段转换到指定时区
- 示例:基本配置
- 应用TimezoneConverter SMT的效果
- 示例:高级配置
- 配置选项
- 当Debezium发出事件记录时,记录中的时间戳字段的时区值可能会有所不同,这取决于数据源的类型和配置。为了在数据处理管道和应用程序中保持数据一致性和精确性,可以使用时区转换器SMT确保事件记录使用一致的时区来表示时间戳数据。
- SMT通过使用converted.timezone配置选项将指定字段的值转换为目标时区。可以将目标时区指定为地理时区,例如America/New_York,也可以指定为UTC偏移,例如+02:00。假设记录的字段都是以UTC时间表示的。除了指定的时区之外,SMT还提供了配置选项,可以使用include.list和exclude.list配置选项来包含或排除特定字段的时区转换。
- SMT支持所有Debezium和Kafka Connect的时态和非时态类型。
注意:
- 为了遵守夏令时规定,必须在converted.timezone配置选项中指定一个地理时区。如果指定了一个UTC偏移,转换器将应用一个固定的UTC偏移,这对于观察夏令时的地区并不准确。当将时间戳字段转换为一个不遵守夏令时的特定时区时,提供一个固定的UTC偏移是有用的。
- include.list和exclude.list配置选项是互斥的。必须只指定其中一个选项。
SMT还允许将源信息块中的事件元数据字段(例如ts_ms)转换为目标时区。为了转换元数据字段,必须在include.list