【惊天巨bug】AddOpFieldForDebeziumRecord无法正确添加__op
Opened this issue · 1 comments
bulolo commented
完整复现过程:https://junyao.tech/posts/e4464a42.html
- mongodb 6.0 、mysql8
- debezium/connect:2.4.2.Final
- kafka 2.4.1
都无法通过AddOpFieldForDebeziumRecord 添加__op:1 或者 __op:0
mysql
"transforms": "addfield,unwrap",
"transforms.addfield.type": "com.starrocks.connector.kafka.transforms.AddOpFieldForDebeziumRecord",
"transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
"transforms.unwrap.drop.tombstones": "true",
"transforms.unwrap.delete.handling.mode": "rewrite"
mongo
"transforms": "addfield,unwrap",
"transforms.addfield.type": "com.starrocks.connector.kafka.transforms.AddOpFieldForDebeziumRecord",
"transforms.unwrap.type": "io.debezium.connector.mongodb.transforms.ExtractNewDocumentState",
"transforms.unwrap.drop.tombstones": "true",
"transforms.unwrap.delete.handling.mode": "rewrite"
bulolo commented