-
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)
/