-
Bug
-
Resolution: Done
-
Major
-
1.6.0.Beta2
-
None
We use connector 1.6 beta2.
ERROR Producer failure (io.debezium.pipeline.ErrorHandler:31) io.debezium.DebeziumException: Could not find column ID in event
Full log file connect.log
Connector config
{"connector.class": "io.debezium.connector.oracle.OracleConnector", "tasks.max": "1", "snapshot.mode": "schema_only", "snapshot.delay.ms": "5000", "heartbeat.interval.ms": "1000", "provide.transaction.metadata": "true", "decimal.handling.mode": "string", "sanitize.field.names": "true", "event.processing.failure.handling.mode": "skip", "database.server.name": "ABCDf2", "database.hostname": "192.168.2.68", "database.port": "1521", "database.user": "logminer", "database.password": "lm", "database.dbname": "ABCDf2", "database.history.kafka.bootstrap.servers": "10.204.192.111:9092,10.204.192.112:9092,10.204.192.113:9092", "database.history.kafka.topic": "history_logminer_160621_v0", "log.mining.archive.log.hours": "1", "log.mining.archive.log.only.mode": "true", "table.include.list": "ABCD_SHARD_1_3.D_LOT_VERSION,ABCD_SHARD_1_3.D_LOT_ENTITY,ABCD_SHARD_1_3.D_LOT_STATUS_HISTORY,ABCD_SHARD_1_3.D_PROCEDURE_LOT_ENTRY,ABCD_SHARD_1_3.D_LOT_LOT_ENTRY,ABCD_SHARD_1_3.D_PROCEDURE_VERSION,ABCD_SHARD_1_3.D_PROCEDURE_ENTITY,ABCD_SHARD_1_3.D_PLAN_SCHEDULE_LOT_ENTRY,ABCD_SHARD_1_3.D_PLAN_SCHEDULE_VERSION,ABCD_SHARD_1_3.D_PLAN_SCHEDULE_ENTITY,ABCD_SHARD_1_3.D_BID,ABCD_SHARD_1_3.D_EA_PARTICIPANT,ABCD_SHARD_1_3.D_LOT_LOTNUM_ENTRY,ABCD_NSI.N_SPGZ,ABCD_NSI.N_CHARACTERISTIC_SPGZ,ABCD_NSI.N_SPGZ_CHARACTERISTIC_SPGZ,ABCD_NSI.N_CHARACTERISTIC_SPGZ_ENUM,ABCD_NSI.N_KPGZ,ABCD_NSI.N_CHARACTERISTIC_KPGZ,ABCD_NSI.N_KPGZ_CHARACTERISTIC_KPGZ,ABCD_NSI.N_CHARACTERISTIC_KPGZ_ENUM,ABCD_NSI.N_KPGZ_CONTRACT_TEMPLATE,ABCD_NSI.N_KPGZ_TECH_TASK,ABCD_NSI.N_CHARACTERISTIC,ABCD_NSI.N_OKEI_SPGZ" }
DDL:
-- auto-generated definition create table D_PLAN_SCHEDULE_VERSION ( ID NUMBER(38) not null constraint PK_SPLAN_VERSION_ID primary key, ENTITY_ID NUMBER(38) not null constraint FK_PSV_PLAN_SCHEDULE_ENTITY references D_PLAN_SCHEDULE_ENTITY, CREATED_DATE TIMESTAMP(6), DELETED_DATE DATE, PUBLICATION_DATE DATE, APPROVED_VERSION NUMBER(38), ACTUAL NUMBER(1), REASON_FOR_CHANGE_ID NUMBER(38), GRBS_APPROVED_SENT_DATE DATE, GRBS_APPROVED_DATE DATE, GRBS_RESULT_OF_REVIEW_ID NUMBER(38), OPERATION_ID NVARCHAR2(50), APPROVED_DATE DATE, DOCX BLOB, DOCX_SIGNATURE BLOB, XML_OOS BLOB, XML_OOS_SIGNATURE BLOB, SIGNER_USER_ID NUMBER(38), DOCX_FILE_ACCESS_CODE NVARCHAR2(50), OOS_XML_FILE_ACCESS_CODE NVARCHAR2(50), OOS_REF_ID NVARCHAR2(50), OOS_USER VARCHAR2(50), OOS_PASSWORD VARCHAR2(50), VERSION NUMBER(10) default 1, STATUS_ID NUMBER(10), DF_REQUEST_ID NUMBER(38), DF_RESULT_OF_REVIEW_ID NUMBER(38), DF_APPROVED_DATE DATE, DF_APPROVED_SENT_DATE DATE, YEAR_SUM NUMBER(19, 2), FO_APPROVAL_RECEIVED NUMBER(1), PRINT_FORM_FILE_ID NUMBER(10), EXCLUDED_PURCHASE_VOLUME NUMBER, PLANNED_PURCHASE_VOLUME NUMBER, AGGREGATE_ANNUAL_CONTR_VALUE NUMBER, ANNUAL_MSP_PURCHASE_VOLUME NUMBER, ANNUAL_ONLY_MSP_PURCHASE_VOL NUMBER, SPGZ_INNOVATION_SUM NUMBER, PLANNED_ONLY_MSP_PURCHASE_VOLUME NUMBER, OOS_VERSION NUMBER(10) ) / create index PLAN_SCHEDULE_VERSION_ENT_ID on D_PLAN_SCHEDULE_VERSION (ENTITY_ID) /