Details
-
Bug
-
Resolution: Obsolete
-
Blocker
-
None
-
0.10.0.Beta1
-
None
Description
and followed the below steps
Oracle Database 11g Enterprise Edition Release 11.2.0.1.0 - 64bit Production ================ sqlplus sys as sysdba alter system set db_recovery_file_dest_size = 5G; mkdir -p /opt/oracle/oradata/recovery_area alter system set db_recovery_file_dest = '/opt/oracle/oradata/recovery_area' scope=spfile; alter system set ENABLE_GOLDENGATE_REPLICATION=true; shutdown immediate startup mount alter database archivelog; alter database open; -Should show "Database log mode: Archive Mode" archive log list CREATE USER inventory IDENTIFIED BY inventory; GRANT CONNECT, resource, unlimited tablespace TO inventory; create table inventory.customers( id varchar2(1000) primary key, name varchar2(200), sex varchar2(100), location varchar2(1000), birth_date date ); ALTER TABLE inventory.customers ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS; CREATE TABLESPACE xstream_adm_tbs DATAFILE '/opt/oracle/oradata/xstream_adm_tbs.dbf' SIZE 25M REUSE AUTOEXTEND ON MAXSIZE UNLIMITED; CREATE USER xstrmadmin IDENTIFIED BY xsa DEFAULT TABLESPACE xstream_adm_tbs QUOTA UNLIMITED ON xstream_adm_tbs; GRANT CREATE SESSION, SET CONTAINER TO xstrmadmin; CREATE TABLESPACE xstream_tbs DATAFILE '/opt/oracle/oradata/xstream_tbs.dbf' SIZE 25M REUSE AUTOEXTEND ON MAXSIZE UNLIMITED; CREATE USER xstrm IDENTIFIED BY xs DEFAULT TABLESPACE xstream_tbs QUOTA UNLIMITED ON xstream_tbs; GRANT CREATE SESSION TO xstrm; GRANT SELECT ON V_$DATABASE to xstrm; GRANT FLASHBACK ANY TABLE TO xstrm; DECLARE tables DBMS_UTILITY.UNCL_ARRAY; schemas DBMS_UTILITY.UNCL_ARRAY; BEGIN tables(1) := 'customers'; schemas(1) := 'inventory'; DBMS_XSTREAM_ADM.CREATE_OUTBOUND( server_name => 'dbzxout', table_names => tables, schema_names => schemas); END; BEGIN DBMS_XSTREAM_ADM.ALTER_OUTBOUND( server_name => 'dbzxout', connect_user => 'xstrm'); END; export LD_LIBRARY_PATH=/home/ceyhun/projects/lab/yakamoz/lib/oci/instantclient_12_2 ./confluent start ./confluent log connect -f ./confluent consume orcl.inventory.customers --from-beginning connector create request: { "name": "inventory-connector", "config": { "connector.class" : "io.debezium.connector.oracle.OracleConnector", "tasks.max" : "1", "database.server.name" : "orcl", "database.hostname" : "localhost", "database.port" : "1521", "database.user" : "xstrm", "database.password" : "xs", "database.dbname" : "orcl", "database.tablename.case.insensitive": true, "table.whitelist": "orcl\\.inventory\\.(.*)", "database.oracle.version": "11", "database.out.server.name" : "dbzxout", "database.history.kafka.bootstrap.servers" : "localhost:9092", "database.history.kafka.topic": "schema-changes.inventory" } }