Debezium-oracle-connect, kafka 连接 ORA-01031答案

【问题标题】：Debezium-oracle-connect, kafka connect ORA-01031Debezium-oracle-connect, kafka 连接 ORA-01031
【发布时间】：2020-04-25 16:24:05
【问题描述】：

我按照官方文档创建了kafka connect。 Kafka2.4 和 Debezium 1.0 Final

{
"name": "oracle-connect",
"config": {
    "connector.class" : "io.debezium.connector.oracle.OracleConnector",
    "tasks.max" : "1",
    "database.server.name" : "orcl",
    "database.hostname" : "xx.xxx.xx.xx",
    "database.port" : "1521",
    "database.user" : "c##xstrm",
    "database.password" : "xs",
    "database.dbname" : "orcl",
    "database.pdb.name" : "pdborcl",
    "database.out.server.name" : "dbzxout",
    "database.history.kafka.bootstrap.servers" : "kafka:9092",
    "database.history.kafka.topic": "schema-changes.inventory"
}}

但是，抛出异常：

ERROR Failed to initialize snapshot context. (io.debezium.relational.RelationalSnapshotChangeEventSource:107)
java.lang.RuntimeException: java.sql.SQLSyntaxErrorException: ORA-01031: insufficient privileges
at io.debezium.connector.oacle.OracleConnection.setSessionToPdb(OracleConnection.java:51)
......
Caused by: java.sql.SQLSyntaxErrorException:ORA-01031: insufficient privileges
at oracle.jdbc.driver.T2CConnection.checkError(T2CConection.java:1002)
.....
ERROR Producer failure (io.debezium.pipeline.ErrorHandler:36)
...........ORA-01031: insufficient privileges.

一开始我就觉得Oracle用户权限有问题。所以windows cmd 连接Oracle。顺便说一句 我的 oracle 版本 12c

sqlplus / as sysdba

和

grant connect, resource, dba to c##xstrm;

但还是例外。问题最有可能出现在Oracle中，但我不知道该怎么做

【问题讨论】：

问题是连接用户ORA-01031: insufficient privileges 缺少某些权限 - 尝试 SQL 跟踪以查看哪个语句失败。
能否请您告诉我用于 kafka 连接的 oracle 实时 cdc 的先决条件是什么？

标签： oracle apache-kafka-connect debezium

【解决方案1】：

看起来像是授权问题。快速浏览文档列出了所需的权限。

GRANT CREATE SESSION to c##xstrm CONTAINER=ALL;

GRANT SET CONTAINER to c##xstrm CONTAINER=ALL;

GRANT SELECT ON V_$DATABASE to c##xstrm CONTAINER=ALL;

将任何表授予 c##xstrm CONTAINER=ALL;

详细说明：https://debezium.io/documentation/reference/connectors/oracle.html#_creating_an_xstream_admin_user_and_a_user_for_the_connector

【讨论】：