Oracle connector signals 3.3.2

[Alex Epifanov]

Hello debezium team. I need to migrate data from oracle to postgres. I use debezium-connector-oracle-3.3.2.Final for source oracle connector.

I created tables on my source side (oracle).

a)

create table alex.t3(id3 number primary key, name3 varchar2(100));
alter table alex.t3 add supplemental log data (all) columns;
insert into alex.t3(id3,name3) values(1,'one');
insert into alex.t3(id3,name3) values(2,'two');
insert into alex.t3(id3,name3) values(3,'three');
commit;

b)

CREATE TABLE alex.debezium_signal (id VARCHAR(42) PRIMARY KEY, type VARCHAR(32) NOT NULL, data VARCHAR(2048) NULL);
alter table alex.debezium_signal add supplemental log data (all) columns;

My source connector config

{
    "name": "conn_source",
    "config": {
        "connector.class" : "io.debezium.connector.oracle.OracleConnector",
        "tasks.max" : "1",
        "topic.creation.default.replication.factor": "1",
        "topic.creation.default.partitions": "1",
        "topic.prefix" : "source",
        "topic.creation.default.compression.type": "zstd",
        "topic.creation.default.cleanup.policy": "delete",
        "topic.creation.default.retention.ms": "86400000",
        "snapshot.mode": "no_data",
        "database.hostname" : "$DB_HOST",
        "database.port" : "$DB_PORT",
        "database.user" : "$DB_USERNAME",
        "database.password" : "$DB_PASSWORD",
        "database.dbname" : "migr",
        "schema.include.list": "alex",
        "table.include.list" : "alex.t3,alex.debezium_signal",
        "schema.history.internal.kafka.bootstrap.servers" : "HOSTNAME:PORT",
        "schema.history.internal.kafka.topic": "source_schema.c",
        "signal.data.collection": "migr.alex.debezium_signal",
        "signal.enabled.channels": "source"
    }
}

I inserted row into my signal table

INSERT INTO alex.debezium_signal (id, type, data) VALUES('signal-1', 'execute-snapshot', '{"data-collections": ["migr.alex.t3"],"type":"incremental"}');
commit;

But I can`t observe any messages about signals in my logs and topic for table alex.t3 wasn`t created

---

[2025-12-08 14:24:10,752] INFO [conn_source|task-0] 10 records sent during previous 00:00:05.066, last recorded offset of {server=source} partition is {commit_scn=null, snapshot_scn=66321263, snapshot=INITIAL, snapshot_completed=false, scn=66321263} (io.debezium.connector.common.BaseSourceTask:368)
[2025-12-08 14:24:15,707] INFO [conn_source|task-0|offsets] WorkerSourceTask{id=conn_source-0} Committing offsets for 10 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask:236)
[2025-12-08 14:26:58,588] INFO [conn_source|task-0] 1 records sent during previous 00:02:47.836, last recorded offset of {server=source} partition is {commit_scn=66322524:1:0a000600e2860100, txSeq=1, txId=090002002f3e0000, snapshot_scn=66321263, scn=66322504} (io.debezium.connector.common.BaseSourceTask:368)
[2025-12-08 14:26:58,589] INFO [conn_source|task-0] The task will send records to topic 'source.ALEX.DEBEZIUM_SIGNAL' for the first time. Checking whether topic exists (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask:511)
[2025-12-08 14:26:58,593] INFO [conn_source|task-0] Creating topic 'source.ALEX.DEBEZIUM_SIGNAL' (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask:520)
[2025-12-08 14:26:58,611] INFO [conn_source|task-0] Created topic (name=source.ALEX.DEBEZIUM_SIGNAL, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={compression.type=zstd, cleanup.policy=delete, retention.ms=86400000}) on brokers at HOSTNAME:PORT (org.apache.kafka.connect.util.TopicAdmin:416)
[2025-12-08 14:26:58,611] INFO [conn_source|task-0] Created topic '(name=source.ALEX.DEBEZIUM_SIGNAL, numPartitions=1, replicationFactor=1, replicasAssignments=null, configs={compression.type=zstd, cleanup.policy=delete, retention.ms=86400000})' using creation group TopicCreationGroup{name='default', inclusionPattern=.*, exclusionPattern=, numPartitions=1, replicationFactor=1, otherConfigs={compression.type=zstd, cleanup.policy=delete, retention.ms=86400000}} (org.apache.kafka.connect.runtime.AbstractWorkerSourceTask:528)
[2025-12-08 14:27:05,722] INFO [conn_source|task-0|offsets] WorkerSourceTask{id=conn_source-0} Committing offsets for 1 acknowledged messages (org.apache.kafka.connect.runtime.WorkerSourceTask:236)

---

Please, help me to solve this problem.

[Chris Cranford]

Hi Alex -

The values used in `signal.data.collection` as well as the table names in the signal are case-sensitive. 
Since Oracle uses upper-case by default unless you create tables using double quotes, these values should be supplied in upper-case.

Does that help?
-cc

--
You received this message because you are subscribed to the Google Groups "debezium" group.
To unsubscribe from this group and stop receiving emails from it, send an email to debezium+u...@googlegroups.com.
To view this discussion visit https://groups.google.com/d/msgid/debezium/CAPxzvE5tHhd97wVuQdwuM6rXOxHKNGWqMccjxStf6R2-vuswnA%40mail.gmail.com.

[Alex Epifanov]

Thanks. It helped.

пн, 8 дек. 2025 г. в 18:45, Chris Cranford <cran...@gmail.com>:

To view this discussion visit https://groups.google.com/d/msgid/debezium/2e0d8286-cc23-411f-8f3a-dad50d9dd362%40gmail.com.