Bug report
What Debezium connector do you use and what version?
1.9.4.Final
What is the connector configuration?
{
"name": "src-ase2-22081s4",
"config":
{
"connector.class": "io.debezium.connector.oracle.OracleConnector",
"key.converter": "io.confluent.connect.avro.AvroConverter",
"key.converter.schema.registry.url": "http://swwkafi01c1.suvanet.ch:8081",
"value.converter": "io.confluent.connect.avro.AvroConverter",
"value.converter.schema.registry.url": "http://swwkafi01c1.suvanet.ch:8081",
"database.url": "url",
"database.user": "user",
"database.password": "ENC[AES256_GCM,data:sIK/KSYlegGs0w==,iv:Vk+jBI/EHDJBPeVbT3pe3KLYUSG00SMo0B+I2WY+6vY=,tag:SXC54XgjqOjoDuT70qiIOA==,type:str]",
"database.dbname": "dbname",
"database.server.name": "servername",
"table.include.list": "ASEDBUSR.DOCBESTELLUNG,ASEDBUSR.DOCBESTEMPFAENGER,ASEDBUSR.DOCBESTPARAMATTR,ASEDBUSR.DOCEMPFPARAMATTR,ASEDBUSR.DOCROUTING,ASEDBUSR.DRITTE,ASEDBUSR.ECLAIMINVOICE,ASEDBUSR.ECLAIMINVOICEDET,ASEDBUSR.ECLAIMKOAMAPPCON,ASEDBUSR.ECLAIMKOAMAPPING,ASEDBUSR.ECLAIMMEDKLASS,ASEDBUSR.ECLAIMPARTNER,ASEDBUSR.ECLAIMPROCESS,ASEDBUSR.ELZAHLUNGEN,ASEDBUSR.EMAIL,ASEDBUSR.EXTZAHLUNGEN",
"snapshot.fetch.size": "10000",
"event.processing.failure.handling.mode": "fail",
"tombstones.on.delete": true,
"message.key.columns": "ASEDBUSR.DOCBESTELLUNG:PKEY;ASEDBUSR.DOCBESTEMPFAENGER:PKEY;ASEDBUSR.DOCBESTPARAMATTR:PKEY;ASEDBUSR.DOCEMPFPARAMATTR:PKEY;ASEDBUSR.DOCROUTING:PKEY;ASEDBUSR.DRITTE:PKEY;ASEDBUSR.ECLAIMINVOICE:PKEY;ASEDBUSR.ECLAIMINVOICEDET:PKEY;ASEDBUSR.ECLAIMKOAMAPPCON:PKEY;ASEDBUSR.ECLAIMKOAMAPPING:PKEY;ASEDBUSR.ECLAIMMEDKLASS:PKEY;ASEDBUSR.ECLAIMPARTNER:PKEY;ASEDBUSR.ECLAIMPROCESS:PKEY;ASEDBUSR.ELZAHLUNGEN:PKEY;ASEDBUSR.EMAIL:PKEY;ASEDBUSR.EXTZAHLUNGEN:PKEY",
"log.mining.strategy": "online_catalog",
"log.mining.archive.destination.name": "LOG_ARCHIVE_DEST_10",
"lob.enabled": true,
"log.mining.transaction.retention.hours": "24",
"internal.log.mining.log.query.max.retries": "10",
"time.precision.mode": "connect",
"tasks.max": "1",
"database.history.kafka.bootstrap.servers": "swwkafi01.suvanet.ch:9092",
"database.history.kafka.topic": "ase.schema-changes.asedbusr",
"database.history.consumer.security.protocol": "SASL_SSL",
"database.history.producer.security.protocol": "SASL_SSL",
"database.history.consumer.sasl.mechanism": "SCRAM-SHA-512",
"database.history.producer.sasl.mechanism": "SCRAM-SHA-512",
"database.history.consumer.sasl.jaas.config": "ENC[AES256_GCM,data:QodTYDbC1PxIrG5PnKnuc9dISHyTNYyzDL8vU+jC1+4uevNi5B3ItpOYNvjL/ppSNac2ncrIDwRMd054U+YyAymuhfTdvjz4AVUjaU5Q5V35H6HUR3BqTtHSF71hiFQSTXoN/6WZ5p/7DXB0/ITrFXfAuQ==,iv:xGTVNto5azYmd2J03Le+0kiPjMv5iRWM+m7kYv4Z+Zk=,tag:y4Nxq7lk7QiM+Mys2SBOsQ==,type:str]",
"database.history.producer.sasl.jaas.config": "ENC[AES256_GCM,data:0oYtrt+g+rHOku9Q1KUkMbtiWxQf0lmqxCJAoYv4rfI7D9IiUQ5JvxJZHXXxahscPa068am6D9LA9dzxqJ7obdr+3jaGb/meHHIt9tIfln7oSoN8st7n4sFJ7C3/8E4mtjE9ivCZrFtLOlwu7kirGuD+Gw==,iv:EsDmauMOyatZAQg59pY8W3YIgvxDfipKnIdx2nj1jQg=,tag:KXW5P3Zqu90Bd8uhZzdiuQ==,type:str]",
"transforms": "unwrap",
"transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
"transforms.unwrap.add.fields": "source.table:META_SRC_TABLENAME,source.ts_ms:META_SRC_TS,op:META_SRC_OP,source.scn:META_SRC_SCN,source.snapshot:META_SRC_SNAPSHOT",
"transforms.unwrap.delete.handling.mode": "rewrite",
"transforms.unwrap.drop.tombstones": false
}
,
"sops": {
"kms": null,
"gcp_kms": null,
"azure_kv": null,
"hc_vault": null,
"age": null,
"lastmodified": "2022-01-31T15:41:38Z",
"mac": "ENC[AES256_GCM,data:M9XjPssFMm1y72OldOPbWkLZk6OKiNEqNz1YAtLHwAtXmfDyXaNGL+rRnM5JSGBOpStAIWMq9PbAU39NJJTBKcKOjpLLlU716705U8qjWo7LULCrhF10TBOqH2uQTlP38xB9NWY5o/UwOckSPRRgVKGWw4eGmy5UEFNhPvVnfio=,iv:Kv3Egsbr7M+SUl3Bq2iFup2bIS+kZwY7aBIa3l8ahlk=,tag:3sTj7FSzV86m1/pzzV8lSA==,type:str]",
"pgp": [
{
"created_at": "2022-01-31T15:41:08Z",
"enc": "-----BEGIN PGP MESSAGE-----\n\nhQEMA243CXYlIAr3AQf/Y9Iwsh3K7M+em98P8p6QMlQhVYYhz1TXd3cCX6URmlhd\nkSNHWx+OQKE/wqeWWZvZB9lHJl2ISoqpPjybgRM5Kje3yafuPY/m1kGdVn8FUtXa\ngbCv+O13Hs3Q8qS1hVowq2cIHipaeBp6rQC6WzPPprJGES8K1IuvHz9TJTP8FEae\nuVACYQUCtE+TFL9nAaP37Bp8Yx1gihKUyNEougHkj/5i5LqxYK/CgT5g1LIJl4Xn\ngQyR/THI+lZ5ZhJlFzHMCh+fCAUqpb+RUvbPHOFr2khBv3uJqBNZfODLUDOkoplr\nHLHYKo6viiL9KvI2zPt3pbTbK8gGtt8Hx7Rn1KAtldJeAfoO0XXPil8yecB7XNYe\nrkhpJlmcN+vVbl0MWImKW5CdTBbttRk7LPJjh6SN+FZtNfVlWFRhKfriQ2o6TUkS\n3vdJyDGjOu0eIM9oresH/1ciezyfXjIzyi8zIBA/vA==\n=RcqY\n-----END PGP MESSAGE-----\n",
"fp": "F7067DB106402AABEBEF13F8C6E64E19DC477D85"
}
],
"encrypted_regex": "(database.password|database.history.consumer.sasl.jaas.config|database.history.producer.sasl.jaas.config)",
"version": "3.7.1"
}
}
What is the captured database version and mode of depoyment?
Oracle 19c, on prem, non-cdb
What behaviour do you see? -> see attached file
"state": "FAILED",
"worker_id": "10.85.80.15:8083",
"trace": "org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer.
This connector will be stopped.\n\
tat io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:50)\n\
tat io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:222)\n\
tat io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60)\n\
tat io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174)\n\
tat io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141)\n\
tat io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)\n\
tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\
tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\
tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\
tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\
tat java.base/java.lang.Thread.run(Thread.java:829)\n
Caused by: io.debezium.text.ParsingException: DDL statement couldn't be parsed. Please open a Jira issue with the statement '\n\n
CREATE TABLE versionCheckTable AS SELECT Tablename as TableName, Attrname as Spalte, DECODE (type, 'Code', type ||';' ||codekopf, type) TYP from ( \n
SELECT mb.Tablename as Tablename, a.Attrname as Attrname,a.type, a.codekopf FROM MetaBO mb\n
INNER JOIN AttributeMeta a ON mb.BOID = a.MetaID\n
WHERE Tablename in ('EClaimProcess','EClaimInvoice','EClaimInvoiceDet','TarifZiffer','TSTarifZiffer','TarifGruppe', 'EClaimMCD', 'EClaimKonstell','EClaimMedKlass','EClaimCaseDet','EClaimNotification', 'EClaimPartner')\n
......