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

Clarify which database name to use for signal.data.collection when using Oracle with pluggable database support

XMLWordPrintable

    • False
    • None
    • False
    • Hide

      i have 2 tables :  DEBEZ.DEBEZ_TEST1 and  DEBEZ.DEBEZ_TEST2

      i start debezium with only DEBEZ.DEBEZ_TEST1 in the include.list.

      i get the events for DEBEZ.DEBEZ_TEST1

      now i add to the include list the tables  DEBEZ.DEBEZ_TEST2. and the signal table  DEBEZ.debezium_signal

      i perform restart to the debezium

      i insert new record into DEBEZ.DEBEZ_TEST2 and receive event from debezium

      run an insert into the signal table

       

      INSERT INTO
       DEBEZ.debezium_signal
      VALUES(
        '10',
        'execute-snapshot',
        '{"data-collections": ["DEBEZ.DEBEZ_TEST2"]}'
      );

      the debezium doesnt perform snapshot on DEBEZ.DEBEZ_TEST2.

      do i miss smth ?  

      Show
      i have 2 tables :   DEBEZ .DEBEZ_TEST1  and   DEBEZ .DEBEZ_TEST2 i start debezium with only DEBEZ.DEBEZ_TEST1 in the include.list. i get the events for DEBEZ .DEBEZ_TEST1 now i add to the include list the tables   DEBEZ .DEBEZ_TEST2. and the signal table   DEBEZ.debezium_signal i perform restart to the debezium i insert new record into DEBEZ .DEBEZ_TEST2  and receive event from debezium run an insert into the signal table   INSERT INTO   DEBEZ.debezium_signal VALUES(   '10',   'execute-snapshot',   '{"data-collections": ["DEBEZ.DEBEZ_TEST2"] }' ); the debezium doesnt perform snapshot on DEBEZ.DEBEZ_TEST2. do i miss smth ?  

      In order to make your issue reports as actionable as possible, please provide the following information, depending on the issue type.

      Bug report

      For bug reports, provide this information, please:

      What Debezium connector do you use and what version?

      oracle connector 1.9.5final

      What is the connector configuration?

      debezium.source.database.port=1521
      debezium.source.database.user=c##dbzuser
      debezium.source.database.password=dbz
      debezium.source.database.dbname=ORCLCDB
      debezium.source.database.server.name=redislabs
      debezium.source.database.pdb.name=ORCLPDB1
      #debezium.source.table.exclude.list=inventory.spatial_ref_sys
      #debezium.source.decimal.handling.mode=double
      debezium.source.table.include.list=DEBEZ.DEBEZ_TEST1,DEBEZ.DEBEZ_TEST2,DEBEZ.debezium_signal
      debezium.source.signal.data.collection=ORCLPDB1.DEBEZ.debezium_signal
      debezium.sink.type=redis
      debezium.sink.redis.address=localhost:12001
      #debezium.sink.redis.password=<REDIS_CONNECT_PASSWORD>
      #debezium.source.database.history.store.only.captured.tables.ddl=true
      debezium.source.connector.class=io.debezium.connector.oracle.OracleConnector
      debezium.source.database.hostname=localhost
      debezium.source.include.schema.changes=false
      debezium.source.tombstones.on.delete=false
      debezium.source.offset.flush.interval.ms=1000
      debezium.source.include.schema.changes=false
      debezium.source.tombstones.on.delete=false
      debezium.source.database.history=io.debezium.server.redis.RedisDatabaseHistory
      debezium.source.offset.storage=io.debezium.server.redis.RedisOffsetBackingStore
      debezium.source.database.history.redis.address=${debezium.sink.redis.address}
      #debezium.source.database.history.redis.password=${debezium.sink.redis.password}

      debezium.transforms=AddPrefix
      debezium.transforms.AddPrefix.type=org.apache.kafka.connect.transforms.RegexRouter
      debezium.transforms.AddPrefix.regex=.*
      debezium.transforms.AddPrefix.replacement=data:$0
      quarkus.log.min-level=TRACE
      quarkus.log.level=TRACE
      quarkus.log.console.json=false

      What is the captured database version and mode of depoyment?

      oracle enterprise 19c

      What behaviour do you expect?

      i am adding an insert to the signal table and expect that the debezium will perform a snapshot 

      What behaviour do you see?

      no snapshot is done by debezium. change-record events with old records are not being sent by debezium

      Do you see the same behaviour using the latest relesead Debezium version?

      yes, working with the lastest version of debez

       

              ccranfor@redhat.com Chris Cranford
              gali.levin gal levin (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              7 Start watching this issue

                Created:
                Updated:
                Resolved: