Дебезиум-oracle -коннект, кафка коннект ORA-01031 - PullRequest
Новая
       37

Дебезиум-oracle -коннект, кафка коннект ORA-01031

1 голос
/ 08 января 2020

Я следовал официальной документации для создания kafka connect. Кафка2.4 и Дебезиум 1.0 Финал 

{
"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 connect Oracle. кстати my oracle версия 12 c

sqlplus / as sysdba

и 

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

Но все же исключение. Проблема, скорее всего, возникает в Oracle, но я не знаю как это сделать

1 Ответ

0 голосов
/ 22 апреля 2020

Похоже, проблема авторизации. В кратком обзоре документации перечислены необходимые разрешения.

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

GRANT SET CONTAINER для c ## xstrm CONTAINER = ALL;

GRANT SELECT на базе данных V_ $ для c ## xstrm CONTAINER = ALL;

GRANT FLASHBACK ЛЮБОЙ ТАБЛИЦЫ ДЛЯ c ## xstrm CONTAINER = ALL;

Для подробных инструкций: https://debezium.io/documentation/reference/connectors/oracle.html#_creating_an_xstream_admin_user_and_a_user_for_the_connector

...