debezium连接器在oracle中更新行时发送的大部分是零

btqmn9zl  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(575)

从oracle debezium连接器的文档中可以看出,当对行执行更新时,它应该发送一条kafka消息,其中包含更新前的行状态的所有数据和更新后的行状态的所有数据。但是,我在几乎所有的字段中都得到了零,除了更新的字段和另一个具有唯一约束的字段,但是debezium没有将其用作键。debezium使用的键是四个字段的组合,这四个字段加在一起是唯一的。下面是我如何创建连接器的。如何让debezium提供所有字段的数据,而不仅仅是更新的字段,或者这是不可能的?

{
    "name": "bom-tables",
    "config": {
        "name": "bom-tables",
        "connector.class": "io.debezium.connector.oracle.OracleConnector",
        "database.server.name": "fake.example.com",
        "database.hostname": "fake2.example.com",
        "snapshot.mode": "initial",
        "database.port": "1521",
        "database.user": "XSTRM",
        "database.password": "FAKE_PASS",
        "database.dbname": "FAKE_DBNAME",
        "database.out.server.name": "DBZXOUT",
        "database.history.kafka.bootstrap.servers": "localhost:9092",
        "database.history.kafka.topic": "schema-changes.inventory",
        "database.tablename.case.insensitive": "true",
        "database.oracle.version": "11",
        "include.schema.changes": "true",
        "table.whitelist": "XXX,YYY",
        "errors.log.enable": "true"
    }
}

谢谢你的帮助。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题