HeaderToValue
例子
提取消息标头在一个事件记录到记录值,配置HeaderToValue
SMT在卡夫卡连接配置连接器。您可以配置转换移除原来的标题或复制。从记录中删除头字段、配置使用的SMT移动
操作。保留原始记录头字段,配置SMT使用复制
操作。例如,要删除标题event_timestamp
和关键
从一个事件消息,添加以下行连接器配置:
变换= moveHeadersToValue transforms.moveHeadersToValue.type = io.debez开云体育官方注册网址ium.transforms.HeaderToValue transforms.moveHeadersToValue。头= event_timestamp关键transforms.moveHeadersToValue.fields =时间戳,来源。id transforms.moveHeadersToValue.operation =移动
下面的示例显示了一个事件的标题和值记录之前和之后的转换。
例1。应用的效果
HeaderToValue
SMT-
前处理的事件记录
HeaderToValue
转换 -
- 头在SMT流程事件记录
{“header_x”: 0,“event_timestamp”: 1626102708861,“关键”:100年,}
- 价值在SMT流程事件记录
-
{“前”:零,“后”:{" id ": 1、“first_name”:“安妮”,“last_name”:“Kretchmar”、“电子邮件”:“annek@noanswer.org”},“源”:{“版本”:“2.1.3。最后”、“连接器”:“postgresql”、“名称”:“PostgreSQL_server”、“ts_ms”: 1559033904863,“快照”:真的,“分贝”:“postgres”、“序列”:“[\“24023119 \”,\“24023128”\]“模式”:“公共”、“表”:“客户”、“txId”: 555年,“lsn”: 24023128,“xmin”:零},“人事处”:“c”、“ts_ms”: 1559033904863}
-
事件记录后的处理
HeaderToValue
转换 -
- 头后,SMT删除指定的字段
{“header_x”: 0}
- 值后,SMT头字段的值
-
{“前”:零,“后”:{" id ": 1、“first_name”:“安妮”,“last_name”:“Kretchmar”、“电子邮件”:“annek@noanswer.org”},“源”:{“版本”:“2.1.3。最后”、“连接器”:“postgresql”、“名称”:“PostgreSQL_server”、“ts_ms”: 1559033904863,“快照”:真的,“分贝”:“postgres”、“序列”:“[\“24023119 \”,\“24023128”\]“模式”:“公共”、“表”:“客户”、“txId”: 555年,“lsn”: 24023128,“xmin”:空,“id”: 100},“人事处”:“c”、“ts_ms event_timestamp“: 1559033904863,: 1626102708861}
配置选项
下表列出了配置选项,您可以使用HeaderToValue
SMT。
财产 |
描述 |
类型 |
默认的 |
有效值 |
重要性 |
一个以逗号分隔的标题名称的记录值将被复制或移动到记录值。 |
列表 |
没有默认值 |
非空列表 |
高 |
|
一个以逗号分隔的字段名称,标题名称中列出的顺序相同 |
列表 |
没有默认值 |
非空列表 |
高 |
|
指定以下选项之一: |
字符串 |
没有默认值 |
移动或复制 |
高 |