页眉对value
实例
提取事件记录信头记录记录值,配置页眉对valuekafka连接器SMT配置可配置变换取原信头或复制信头删除记录页眉字段时,配置 smt使用移动运维要保留原记录页眉字段,配置SMT使用拷贝操作.例举清除信头事件-timestamp并密钥从事件消息中添加线程到连接器配置
开云体育官方注册网址transforms=moveHeadersToValue transforms.moveHeadersToValue.type=io.debezium.transforms.HeaderToValue transforms.moveHeadersToValue.headers=event_timestamp,key transforms.moveHeadersToValue.fields=timestamp,source.id transforms.moveHeadersToValue.operation=move下示例显示事件记录前后页眉和值
实例1效果应用
页眉对valueSMT系统
-
事件记录处理前
页眉对value变换 -
- 页眉处理事件记录
{标题_x:0/event-timestamp:1626102861/key:100}- SMT处理事件记录前值
-
{ "before": null, "after": { "id": 1, "first_name": "Anne", "last_name": "Kretchmar", "email": "annek@noanswer.org" }, "source": { "version": "2.1.3.Final", "connector": "postgresql", "name": "PostgreSQL_server", "ts_ms": 1559033904863, "snapshot": true, "db": "postgres", "sequence": "[\"24023119\",\"24023128\"]" "schema": "public", "table": "customers", "txId": 555, "lsn": 24023128, "xmin": null }, "op": "c", "ts_ms": 1559033904863 }
-
事件记录处理后
页眉对value变换 -
- 页眉后SMT删除指定字段
{标题_x:0}- 值后SMT标题字段移入值
-
{ "before": null, "after": { "id": 1, "first_name": "Anne", "last_name": "Kretchmar", "email": "annek@noanswer.org" }, "source": { "version": "2.1.3.Final", "connector": "postgresql", "name": "PostgreSQL_server", "ts_ms": 1559033904863, "snapshot": true, "db": "postgres", "sequence": "[\"24023119\",\"24023128\"]" "schema": "public", "table": "customers", "txId": 555, "lsn": 24023128, "xmin": null, "id": 100 }, "op": "c", "ts_ms": 1559033904863, "event_timestamp": 1626102708861 }