从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"
}
}
谢谢你的帮助。
暂无答案!
目前还没有任何答案,快来回答吧!