【惊天巨bug】AddOpFieldForDebeziumRecord无法正确添加__op

[bulolo]

完整复现过程：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]

实际加不上__op