-
Bug
-
Resolution: Done
-
Major
-
None
-
None
Bug report
What Debezium connector do you use and what version?
debezium-connector-informix:3.3.1.Final
What is the connector configuration?
{
"connector.class": "io.debezium.connector.informix.InformixConnector",
"database.hostname": hostname,
"database.port": port,
"database.user": username,
"database.password": password,
"database.dbname": dbname,
"cdc.timeout": 0,
"cdc.buffersize": 10000000,
"topic.prefix": "topic.prefix",
"table.include.list": "...",
"time.precision.mode": "connect",
"tombstones.on.delete": false,
"include.schema.changes": false,
"schema.name.adjustment.mode": "avro",
"field.name.adjustment.mode": "avro",
"sanitize.field.names": true,
"snapshot.mode": "no_data",
"snapshot.isolation.mode": "read_committed",
"incremental.snapshot.chunk.size": 10000,
"incremental.snapshot.watermarking.strategy": "insert_delete",
"event.processing.failure.handling.mode": "warn",
"heartbeat.interval.ms": 100000,
"provide.transaction.metadata": true,
"signal.enabled.channels": "source,kafka",
"signal.data.collection": "debezium_signal",
"signal.kafka.topic": "debezium_signal",
"signal.kafka.bootstrap.servers": "...",
"signal.consumer.socket.connection.setup.timeout.ms": 30000,
"signal.consumer.socket.connection.setup.timeout.max.ms": 90000,
"schema.history.internal.kafka.topic": "schemahistory",
"schema.history.internal.kafka.bootstrap.servers": "...",
"schema.history.internal.skip.unparseable.ddl": true,
"schema.history.internal.store.only.captured.tables.ddl": false,
"schema.history.internal.store.only.captured.databases.ddl": true,
"errors.log.enable": true,
"errors.log.include.messages": true
}
What is the captured database version and mode of deployment?
on-prem informix 14
What behavior do you expect?
When a transaction is aborted with rollback there should both a BEGIN and END marker dispatched or none at all.
What behavior do you see?
We see only a BEGIN marker.
Do you see the same behaviour using the latest released Debezium version?
Yes
Do you have the connector logs, ideally from start till finish?
No
How to reproduce the issue using our tutorial deployment?
Add "provide.transaction.metadata": true," to register-ifx.json
Change kafka consumer to listen to "ifxserver.transaction"
Change sql statement to:
BEGIN WORK; INSERT INTO informix.customers(first_name, last_name, email) VALUES ('John', 'Doe', 'john.doe@example.com'); ROLLBACK; BEGIN WORK; INSERT INTO informix.customers(first_name, last_name, email) VALUES ('John', 'Doe', 'john.doe@example.com'); COMMIT;
