没有为捕获的元数据注册 table ORCLCDB.ROOT.TEST

No metadata registered for captured table ORCLCDB.ROOT.TEST

在 TEST table 上插入内容后发生此错误。

[2020-02-15 15:20:03,996] ERROR Producer failure (io.debezium.pipeline.ErrorHandler:36)
**java.lang.IllegalArgumentException: No metadata registered for captured table ORCLCDB.ROOT.TEST**
    at io.debezium.pipeline.EventDispatcher.errorOnMissingSchema(EventDispatcher.java:168)
    at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:138)
    at io.debezium.connector.oracle.LcrEventHandler.dispatchDataChangeEvent(LcrEventHandler.java:102)
    at io.debezium.connector.oracle.LcrEventHandler.processLCR(LcrEventHandler.java:76)
    at oracle.streams.XStreamOut.XStreamOutReceiveLCRCallbackNative(Native Method)
    at oracle.streams.XStreamOut.receiveLCRCallback(XStreamOut.java:465)
    at io.debezium.connector.oracle.OracleStreamingChangeEventSource.execute(OracleStreamingChangeEventSource.java:74)
    at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start[=12=](ChangeEventSourceCoordinator.java:99)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)

连接器-oracle-source.properties:

name=oracle-connector
connector.class=io.debezium.connector.oracle.OracleConnector
tasks.max=1
database.hostname=192.168.6.36
database.port=1521
database.user=c##xstrm
database.password=xs
database.server.name=osTomates
database.out.server.name=teucude4
database.dbname=ORCLCDB
#database.pdb.name=ORCLPDB1
database.history.kafka.bootstrap.servers=192.168.6.36:9092
database.history.kafka.topic=test

如果您需要更多信息,请告诉我?

甲骨文19版本 独立配置

用户 c##xstrm 应该获得查看 root.test table 的权限(就我而言)。

GRANT SELECT ON root.test TO c##xstrm;

这解决了我的问题。

如果接下来您在重启 kafka 连接后收到此错误 ORA-31603,这对我有用:

GRANT select_catalog_role TO c##xstrm;

希望这对外面的人有所帮助。