转换

连接器可以配置转换,以对每个消息进行轻量级修改。开云体育官方注册网址Debezium提供了几个单个消息转换(smt),您可以使用它在记录发送到Apache Kafka之前(通过将它们应用到Debezium连接器)修改记录,或者当它们由接收器连接器从Kafka读取时。开云体育官方注册网址也开云体育官方注册网址Debezium服务器支持smt的使用。

以下smt由Debezium提供:开云体育官方注册网址

变换 描述

基于应用于原始主题名称的正则表达式将记录重新路由到不同的主题。

根据事件内容将所选事件重新路由到其他主题。

从Debezium更改事件中提取字段名和值的扁平结构,方便接收器连接器,而接收器连接器不能处理Debezium复杂的事开云体育官方注册网址件结构。

蒙古特有的对应新记录状态提取SMT。

提供一种在多个(微)服务之间安全可靠地交换数据的方法。

蒙古特有的对应发件箱事件路由器SMT。

根据连接器的内容,对连接器发出的更改事件应用筛选器。这允许您只传播与您相关的记录。

根据配置的表列将记录重新路由到特定分区。

通过SMT谓词您可以有选择地应用任何转换,以便它只修改具有共同特征的变更事件消息的子集。

在Debezium容器映像默认情况下,上述大多数smt都是可用的,但是需要选择使用基于脚本的smt(消息过滤或基于开云体育官方注册网址内容的路由)。看到自述容器映像文件以获取更多详细信息。