через дебезиум и кафку. Настраиваю пример из доки https://debezium.io/documentation/reference/1.3/tutorial.html
база, зукипер, кафка, коннект запущены.
Добавляю коннект для оракла и вижу в логе вот такую ошибку
2023-05-03 11:43:38,790 INFO || Snapshot step 1 - Preparing [io.debezium.relational.RelationalSnapshotChangeEventSource]
2023-05-03 11:43:38,869 INFO || Snapshot step 2 - Determining captured tables [io.debezium.relational.RelationalSnapshotChangeEventSource]
2023-05-03 11:43:39,248 INFO || Snapshot step 3 - Locking captured tables [io.debezium.relational.RelationalSnapshotChangeEventSource]
2023-05-03 11:43:39,253 INFO || Snapshot step 4 - Determining snapshot offset [io.debezium.relational.RelationalSnapshotChangeEventSource]
2023-05-03 11:43:39,265 INFO || Snapshot - Final stage [io.debezium.pipeline.source.AbstractSnapshotChangeEventSource]
2023-05-03 11:43:39,268 ERROR || Producer failure [io.debezium.pipeline.ErrorHandler]
java.lang.RuntimeException: java.sql.SQLSyntaxErrorException: ORA-00942: table or view does not exist
...
Caused by: Error : 942, Position : 24, SQL = SELECT CURRENT_SCN FROM V$DATABASE, Original SQL = SELECT CURRENT_SCN FROM V$DATABASE, Error Message = ORA-00942: table or view does not exist
гуглеж ошибки намекает что у юзера нет прав на чтение.
Однако если к базе подключаюсь под этим пользователем, то запрос нормально отрабатывает. Да и в скрипте настройки логмайнера явно видно команду предоставления прав
GRANT SELECT ON V_\$DATABASE TO dbzuser;
Что еще может быть причиной, куда копнуть?
регистр не проверял, upper/lower?
я так понимаю в таком виде как в логе то есть в upper и запрашивается. а ручной запрос в таком виде корректно работает
Обсуждают сегодня