Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-1360

Can't receive change events with oracle connector - JDBC getTables() hangs

    XMLWordPrintable

Details

    • Bug
    • Resolution: Obsolete
    • Blocker
    • None
    • 0.10.0.Beta1
    • oracle-connector
    • 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"
      	}
      }
      
      

      Attachments

        Activity

          People

            ccranfor@redhat.com Chris Cranford
            ceyhun.kerti@bluecolor.io Ceyhun Kerti (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            6 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: