-
Bug
-
Resolution: Done
-
Major
-
3.2.0.Final
-
None
-
False
-
-
False
What Debezium connector do you use and what version?
Oracle Connector 3.2.Final
What is the connector configuration?
{ "connector.class": "io.debezium.connector.oracle.OracleConnector", "key.converter": "io.confluent.connect.avro.AvroConverter", "key.converter.schema.registry.url": "kafka:8081", "value.converter": "io.confluent.connect.avro.AvroConverter", "value.converter.schema.registry.url": "kafka:8081", "schema.name.adjustment.mode": "avro", "database.hostname": "DBHOST", "database.port": "1521", "database.user": "DBZUSER", "database.password": "", "database.dbname": "DB", "database.pdb.name": "PDB", "database.query.timeout.ms": 0, "topic.prefix": "ASE5", "schema.exclude.list": "AUDSYS", "table.include.list": "ASEDBUSR.LAND,ASEDBUSR.LEGALCOLLCLAIM,ASEDBUSR.LEISTUNGSERBRINGER,ASEDBUSR.LEISTUNGSFALL,ASEDBUSR.LOHNANGABE,ASEDBUSR.LOHNDEKLDET,ASEDBUSR.LOHNDEKLDETKOMP,ASEDBUSR.LOHNDEKLDETSS,ASEDBUSR.LOHNDEKLHEAD,ASEDBUSR.LOHNDEKLKOMPDEF,ASEDBUSR.LSTABRECHNUNG,ASEDBUSR.LSTABRECHNUNGTYP,ASEDBUSR.LSTABRPOSITION,ASEDBUSR.LSTABRPRODPOS,ASEDBUSR.LSTBEGUENSTIGTER,ASEDBUSR.LSTFALLKUERZUNG,ASEDBUSR.LSTFREIGABEPROC,ASEDBUSR.LSTKATEGORIE,ASEDBUSR.LSTZAHLER,ASEDBUSR.MAHNSTUFE,ASEDBUSR.MAPPING,ASEDBUSR.MAPPINGDEF,ASEDBUSR.MELDEPARTNER,ASEDBUSR.MERKMALZUSATZATTR,ASEDBUSR.MINIMALPRAEMIE,ASEDBUSR.MINIMALPRMDEF,ASEDBUSR.MUTATIONSGRUND,ASEDBUSR.NOTES,ASEDBUSR.NOTESTYPE", "snapshot.select.statement.overrides": "ASEDBUSR.LAND,ASEDBUSR.LEGALCOLLCLAIM,ASEDBUSR.LEISTUNGSERBRINGER,ASEDBUSR.LEISTUNGSFALL,ASEDBUSR.LOHNANGABE,ASEDBUSR.LOHNDEKLDET,ASEDBUSR.LOHNDEKLDETKOMP,ASEDBUSR.LOHNDEKLDETSS,ASEDBUSR.LOHNDEKLHEAD,ASEDBUSR.LOHNDEKLKOMPDEF,ASEDBUSR.LSTABRECHNUNG,ASEDBUSR.LSTABRECHNUNGTYP,ASEDBUSR.LSTABRPOSITION,ASEDBUSR.LSTABRPRODPOS,ASEDBUSR.LSTBEGUENSTIGTER,ASEDBUSR.LSTFALLKUERZUNG,ASEDBUSR.LSTFREIGABEPROC,ASEDBUSR.LSTKATEGORIE,ASEDBUSR.LSTZAHLER,ASEDBUSR.MAHNSTUFE,ASEDBUSR.MAPPING,ASEDBUSR.MAPPINGDEF,ASEDBUSR.MELDEPARTNER,ASEDBUSR.MERKMALZUSATZATTR,ASEDBUSR.MINIMALPRAEMIE,ASEDBUSR.MINIMALPRMDEF,ASEDBUSR.MUTATIONSGRUND,ASEDBUSR.NOTES,ASEDBUSR.NOTESTYPE", "snapshot.select.statement.overrides.ASEDBUSR.LAND": "SELECT * FROM ASEDBUSR.LAND AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LEGALCOLLCLAIM": "SELECT * FROM ASEDBUSR.LEGALCOLLCLAIM AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LEISTUNGSERBRINGER": "SELECT * FROM ASEDBUSR.LEISTUNGSERBRINGER AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LEISTUNGSFALL": "SELECT * FROM ASEDBUSR.LEISTUNGSFALL AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LOHNANGABE": "SELECT * FROM ASEDBUSR.LOHNANGABE AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LOHNDEKLDET": "SELECT * FROM ASEDBUSR.LOHNDEKLDET AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LOHNDEKLDETKOMP": "SELECT * FROM ASEDBUSR.LOHNDEKLDETKOMP AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LOHNDEKLDETSS": "SELECT * FROM ASEDBUSR.LOHNDEKLDETSS AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LOHNDEKLHEAD": "SELECT * FROM ASEDBUSR.LOHNDEKLHEAD AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LOHNDEKLKOMPDEF": "SELECT * FROM ASEDBUSR.LOHNDEKLKOMPDEF AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LSTABRECHNUNG": "SELECT * FROM ASEDBUSR.LSTABRECHNUNG AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LSTABRECHNUNGTYP": "SELECT * FROM ASEDBUSR.LSTABRECHNUNGTYP AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LSTABRPOSITION": "SELECT * FROM ASEDBUSR.LSTABRPOSITION AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LSTABRPRODPOS": "SELECT * FROM ASEDBUSR.LSTABRPRODPOS AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LSTBEGUENSTIGTER": "SELECT * FROM ASEDBUSR.LSTBEGUENSTIGTER AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LSTFALLKUERZUNG": "SELECT * FROM ASEDBUSR.LSTFALLKUERZUNG AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LSTFREIGABEPROC": "SELECT * FROM ASEDBUSR.LSTFREIGABEPROC AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LSTKATEGORIE": "SELECT * FROM ASEDBUSR.LSTKATEGORIE AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.LSTZAHLER": "SELECT * FROM ASEDBUSR.LSTZAHLER AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.MAHNSTUFE": "SELECT * FROM ASEDBUSR.MAHNSTUFE AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.MAPPING": "SELECT * FROM ASEDBUSR.MAPPING AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.MAPPINGDEF": "SELECT * FROM ASEDBUSR.MAPPINGDEF AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.MELDEPARTNER": "SELECT * FROM ASEDBUSR.MELDEPARTNER AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.MERKMALZUSATZATTR": "SELECT * FROM ASEDBUSR.MERKMALZUSATZATTR AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.MINIMALPRAEMIE": "SELECT * FROM ASEDBUSR.MINIMALPRAEMIE AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.MINIMALPRMDEF": "SELECT * FROM ASEDBUSR.MINIMALPRMDEF AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.MUTATIONSGRUND": "SELECT * FROM ASEDBUSR.MUTATIONSGRUND AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.NOTES": "SELECT * FROM ASEDBUSR.NOTES AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "snapshot.select.statement.overrides.ASEDBUSR.NOTESTYPE": "SELECT * FROM ASEDBUSR.NOTESTYPE AS OF SCN ORDER BY CREATED ASC, PKEY ASC", "internal.snapshot.enhance.predicate.scn": "AS OF SCN", "snapshot.fetch.size": "10000", "snapshot.max.threads": 3, "snapshot.mode": "initial", "snapshot.include.collection.list": ".*", "signal.data.collection": "DB.DBZUSER.DBZSIGNALASE5", "heartbeat.interval.ms": 60000, "heartbeat.action.query": "UPDATE DBZUSER.DBZHEARTBEATASE5 SET BEAT = SYSDATE", "producer.override.batch.size": 1000000, "producer.override.linger.ms": 500, "producer.override.compression.type": "lz4", "event.processing.failure.handling.mode": "fail", "tombstones.on.delete": "true", "skip.messages.without.change": "true", "message.key.columns": "ASEDBUSR.LAND:BOID;ASEDBUSR.LEGALCOLLCLAIM:BOID;ASEDBUSR.LEISTUNGSERBRINGER:BOID;ASEDBUSR.LEISTUNGSFALL:BOID;ASEDBUSR.LOHNANGABE:BOID;ASEDBUSR.LOHNDEKLDET:BOID;ASEDBUSR.LOHNDEKLDETKOMP:BOID;ASEDBUSR.LOHNDEKLDETSS:BOID;ASEDBUSR.LOHNDEKLHEAD:BOID;ASEDBUSR.LOHNDEKLKOMPDEF:BOID;ASEDBUSR.LSTABRECHNUNG:BOID;ASEDBUSR.LSTABRECHNUNGTYP:BOID;ASEDBUSR.LSTABRPOSITION:BOID;ASEDBUSR.LSTABRPRODPOS:BOID;ASEDBUSR.LSTBEGUENSTIGTER:BOID;ASEDBUSR.LSTFALLKUERZUNG:BOID;ASEDBUSR.LSTFREIGABEPROC:BOID;ASEDBUSR.LSTKATEGORIE:BOID;ASEDBUSR.LSTZAHLER:BOID;ASEDBUSR.MAHNSTUFE:BOID;ASEDBUSR.MAPPING:BOID;ASEDBUSR.MAPPINGDEF:BOID;ASEDBUSR.MELDEPARTNER:BOID;ASEDBUSR.MERKMALZUSATZATTR:BOID;ASEDBUSR.MINIMALPRAEMIE:BOID;ASEDBUSR.MINIMALPRMDEF:BOID;ASEDBUSR.MUTATIONSGRUND:BOID;ASEDBUSR.NOTES:BOID;ASEDBUSR.NOTESTYPE:BOID", "log.mining.strategy": "hybrid", "log.mining.transaction.retention.ms": 50000000, "log.mining.query.filter.mode": "in", "log.mining.batch.size.max": 200000, "log.mining.batch.size.min": 40000, "log.mining.batch.size.default": 40000, "internal.log.mining.log.query.max.retries": "10", "internal.log.mining.sql.relaxed.quote.detection": "true", "archive.destination.name": "LOG_ARCHIVE_DEST_10", "lob.enabled": "false", "unavailable.value.placeholder": "previous_value_unchanged", "time.precision.mode": "connect", "tasks.max": "1", "schema.history.internal.store.only.captured.tables.ddl": "true", "schema.history.internal.kafka.bootstrap.servers": "kafka:9092", "schema.history.internal.kafka.topic": "ase.schema-changes.asedbusr", "schema.history.internal.consumer.security.protocol": "SASL_SSL", "schema.history.internal.producer.security.protocol": "SASL_SSL", "schema.history.internal.consumer.sasl.mechanism": "SCRAM-SHA-512", "schema.history.internal.producer.sasl.mechanism": "SCRAM-SHA-512", "schema.history.internal.consumer.sasl.jaas.config": "", "schema.history.internal.producer.sasl.jaas.config": "", "notification.enabled.channels": "sink", "notification.sink.topic.name": "ASE5.SNAPSHOT.STATUS", "transforms": "changes,moveHeadersToValue,unwrap,reroute,filter", "transforms.changes.type": "io.debezium.transforms.ExtractChangedRecordState", "transforms.changes.header.changed.name": "Changed", "transforms.moveHeadersToValue.type": "io.debezium.transforms.HeaderToValue", "transforms.moveHeadersToValue.headers": "Changed", "transforms.moveHeadersToValue.fields": "changes", "transforms.moveHeadersToValue.operation": "move", "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState", "transforms.unwrap.add.fields": "source.table:META_SRC_TABLENAME,source.ts_ms:META_SRC_TS_MS,ts_ms:META_TS_MS,ts_us:META_TS_US,op:META_SRC_OP,source.scn:META_SRC_SCN,source.snapshot:META_SRC_SNAPSHOT,source.user_name:META_SRC_USER,changes:META_SRC_CHANGES", "transforms.unwrap.delete.tombstone.handling.mode": "rewrite-with-tombstone", "transforms.reroute.type": "io.debezium.transforms.ByLogicalTableRouter", "transforms.reroute.topic.regex": "(.*)debezium-heartbeat.ASE(.*)", "transforms.reroute.topic.replacement": "ASE5.DEBEZIUM.HEARTBEAT", "transforms.filter.type": "org.apache.kafka.connect.transforms.Filter", "transforms.filter.predicate": "isSignal", "predicates": "isSignal", "predicates.isSignal.type": "org.apache.kafka.connect.transforms.predicates.TopicNameMatches", "predicates.isSignal.pattern": ".*DBZSIGNALASE5", "post.processors": "reselector", "reselector.type": "io.debezium.processors.reselect.ReselectColumnsPostProcessor", "reselector.reselect.columns.include.list": "ASEDBUSR.LEISTUNGSFALL:BEGRUENDSTELLNAHME,ASEDBUSR.LSTABRECHNUNG:INTERNCOMMENT,ASEDBUSR.LSTABRPRODPOS:POSPRODCOMMENT,ASEDBUSR.LSTFREIGABEPROC:BEMERKUNG,ASEDBUSR.NOTES:NOTE", "reselector.reselect.unavailable.values": "true", "reselector.reselect.null.values": "true" }What is the captured database version and mode of deployment?
Oracle 19.25 on prem, CDB, extended stringsize
What behavior do you expect?
Create event with sinqle quotes as in the source db's string:
"DIAGNOSETEXT": "Hypersignal du LCA probablement séquellaire d'une ancienne entorse ou d'une dégénérescence mucoïde. Présence d'un kyste arthrosynovial à développement postéro-latéral en arrière du condyle fémoral externe polylobulé et aussi un 2ème kyste arthrosynovial"
What behavior do you see?
Create event with double quotes instead of single quotes:
"DIAGNOSETEXT": "Hypersignal du LCA probablement séquellaire d''une ancienne entorse ou d''une dégénérescence mucoïde. Présence d''un kyste arthrosynovial à développement postéro-latéral en arrière du condyle fémoral externe polylobulé et aussi un 2ème kyste arthrosynovial"