-
Bug
-
Resolution: Done
-
Major
-
2.6.0.Beta1
-
None
-
False
-
None
-
False
Bug report
For bug reports, provide this information, please:
What Debezium connector do you use and what version?
debezium-connector-oracle version 2.6.0.Alpha2
What is the connector configuration?
{
"name": "source-test-connector",
"config": {
"connector.class": "io.debezium.connector.oracle.OracleConnector",
"tasks.max": "1",
"database.hostname": "oracle",
"database.port": "1521",
"database.user": "c##dbzuser",
"database.password": "dbz",
"database.dbname": "orclcdb",
"database.pdb.name": "orclpdb1",
"database.connection.adapter": "logminer",
"topic.prefix": "dbz",
"schema.name.adjustment.mode": "avro",
"table.include.list": "C##DBZUSER.TEST_TABLE",
"include.schema.changes": "false",
"schema.history.internal.kafka.bootstrap.servers" : "kafka:9092",
"schema.history.internal.kafka.topic": "schema-changes.test",
"heartbeat.interval.ms": "60000",
"log.mining.strategy": "online_catalog",
"log.mining.query.filter.mode": "in",
"custom.metric.tags": "connector=source-test-connector",
"transforms": "unwrap",
"transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
"key.converter": "org.apache.kafka.connect.json.JsonConverter",
"key.converter.schemas.enable": "false",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.converter.schemas.enable": "false"
}
}
What is the captured database version and mode of deployment?
Oracle Database 19, Docker
What behaviour do you expect?
The metric ScnFreezeCount increases while a long transaction is active.
What behaviour do you see?
The metric ScnFreezeCount never increases even if there is a long transaction.
Do you see the same behaviour using the latest relesead Debezium version?
Yes
Feature request or enhancement
https://github.com/debezium/debezium/pull/5364
How to reproduce the issue using our tutorial deployment?
1. Create a new table:
CREATE TABLE c##dbzuser.test_table ( id NUMBER(10) NOT NULL PRIMARY KEY, text VARCHAR2(300) );
2. Create a new connector:
curl -X POST -H "Accept:application/json" -H "Content-Type:application/json" http://localhost:8083/connectors -d '
{
"name": "source-test-connector",
"config": {
"connector.class": "io.debezium.connector.oracle.OracleConnector",
"tasks.max": "1",
"database.hostname": "oracle",
"database.port": "1521",
"database.user": "c##dbzuser",
"database.password": "dbz",
"database.dbname": "orclcdb",
"database.pdb.name": "orclpdb1",
"database.connection.adapter": "logminer",
"topic.prefix": "dbz",
"schema.name.adjustment.mode": "avro",
"table.include.list": "C##DBZUSER.TEST_TABLE",
"include.schema.changes": "false",
"schema.history.internal.kafka.bootstrap.servers" : "kafka:9092",
"schema.history.internal.kafka.topic": "schema-changes.test",
"heartbeat.interval.ms": "60000",
"log.mining.strategy": "online_catalog",
"log.mining.query.filter.mode": "in",
"custom.metric.tags": "connector=source-test-connector",
"transforms": "unwrap",
"transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
"key.converter": "org.apache.kafka.connect.json.JsonConverter",
"key.converter.schemas.enable": "false",
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.converter.schemas.enable": "false"
}
}'
3. Insert a new record into the table without transaction commit:
INSERT INTO c##dbzuser.test_table (id, text) VALUES (1, 'text');
4. Check the metric after some time.
ER:
# HELP debezium_connector_scnfreezecount Debezium connector metrics
# TYPE debezium_connector_scnfreezecount gauge
debezium_connector_scnfreezecount{connector="source-data-types-connector",context="streaming",plugin="oracle",server="logminer",task="0",} 1.0
AR:
# HELP debezium_connector_scnfreezecount Debezium connector metrics
# TYPE debezium_connector_scnfreezecount gauge
debezium_connector_scnfreezecount{connector="source-data-types-connector",context="streaming",plugin="oracle",server="logminer",task="0",} 0.0
- links to
-
RHEA-2024:129636
Red Hat build of Debezium 2.5.4 release
