kafka-connect | [2021-10-27 19:35:54,122] DEBUG [source-oracle-dbz-xstream-00|task-0] Processing DML event DefaultRowLCR: kafka-connect | Header: kafka-connect | source database name: ORCLPDB1 kafka-connect | command type: INSERT kafka-connect | object owner: PRISM_JOB kafka-connect | object name: JOB kafka-connect | tag: [] kafka-connect | position: [0 0 0 0 0 37 ffffffb2 ffffffaf 0 0 0 1 0 0 0 1 0 0 0 0 0 37 ffffffb2 ffffffa4 0 0 0 3 0 0 0 1 2] kafka-connect | transaction id: 1.26.721 kafka-connect | source time: 2021-10-27 19:35:49 kafka-connect | scn: null kafka-connect | commit scn: null kafka-connect | lcr flags: kafka-connect | Statement LCR: false kafka-connect | IDKeyColumnsOnly LCR: false kafka-connect | Sequence LCR: false kafka-connect | Attribute[2] kafka-connect | (0): ROOT_NAME : ORCLCDB kafka-connect | (1): ROW_ID : AAASIkAAMAAAAHMAAA kafka-connect | Old column values (0): kafka-connect | New column values (2): kafka-connect | (0): DefaultColumnValue(csid:0, tde:false, type:0, name:ID, data:5000000.0) kafka-connect | (1): DefaultColumnValue(csid:0, tde:false, type:0, name:NAME, data:name4) kafka-connect | (io.debezium.connector.oracle.xstream.LcrEventHandler:148) kafka-connect | [2021-10-27 19:35:54,123] INFO [source-oracle-dbz-xstream-00|task-0] Table ORCLPDB1.PRISM_JOB.JOB is new and will be captured. (io.debezium.connector.oracle.xstream.LcrEventHandler:160) kafka-connect | [2021-10-27 19:35:54,176] DEBUG [source-oracle-dbz-xstream-00|task-0] Connected to jdbc:oracle:oci:@oracle:1521/ORCLCDB with {history.kafka.topic=schema-changes.inventory, out.server.name=dbzxout, user=c##xstrm, password=***, server.name=asgard, history.kafka.bootstrap.servers=kafka:29092, pdb.name=ORCLPDB1, connection.adapter=xstream} (io.debezium.jdbc.JdbcConnection:187) kafka-connect | [2021-10-27 19:35:54,178] INFO [source-oracle-dbz-xstream-00|task-0] Database Version: Oracle Database 19c Enterprise Edition Release 19.0.0.0.0 - Production kafka-connect | Version 19.3.0.0.0 (io.debezium.connector.oracle.OracleConnection:75) kafka-connect | [2021-10-27 19:35:54,560] INFO [source-oracle-dbz-xstream-00|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965) kafka-connect | [2021-10-27 19:35:54,565] INFO [source-oracle-dbz-xstream-00|task-0] KafkaDatabaseHistory Consumer config: {enable.auto.commit=false, value.deserializer=org.apache.kafka.common.serialization.StringDeserializer, group.id=asgard-dbhistory, auto.offset.reset=earliest, session.timeout.ms=10000, bootstrap.servers=kafka:29092, client.id=asgard-dbhistory, key.deserializer=org.apache.kafka.common.serialization.StringDeserializer, fetch.min.bytes=1} (io.debezium.relational.history.KafkaDatabaseHistory:219) kafka-connect | [2021-10-27 19:35:54,566] INFO [source-oracle-dbz-xstream-00|task-0] KafkaDatabaseHistory Producer config: {bootstrap.servers=kafka:29092, value.serializer=org.apache.kafka.common.serialization.StringSerializer, buffer.memory=1048576, retries=1, key.serializer=org.apache.kafka.common.serialization.StringSerializer, client.id=asgard-dbhistory, linger.ms=0, batch.size=32768, max.block.ms=10000, acks=1} (io.debezium.relational.history.KafkaDatabaseHistory:220) kafka-connect | [2021-10-27 19:35:54,566] INFO [source-oracle-dbz-xstream-00|task-0] Requested thread factory for connector OracleConnector, id = asgard named = db-history-config-check (io.debezium.util.Threads:270) kafka-connect | [2021-10-27 19:35:54,570] DEBUG [source-oracle-dbz-xstream-00|task-0] checking for more records... (io.debezium.connector.base.ChangeEventQueue:251) kafka-connect | [2021-10-27 19:35:54,572] DEBUG [source-oracle-dbz-xstream-00|task-0] polling records... (io.debezium.connector.base.ChangeEventQueue:234) kafka-connect | [2021-10-27 19:35:54,575] DEBUG [source-oracle-dbz-xstream-00|task-0] no records available yet, sleeping a bit... (io.debezium.connector.base.ChangeEventQueue:243) kafka-connect | [2021-10-27 19:35:54,600] DEBUG [source-oracle-dbz-xstream-00|task-0] Applying schema change event SchemaChangeEvent [database=ORCLPDB1, schema=PRISM_JOB, ddl=CREATE TABLE "PRISM_JOB"."JOB" kafka-connect | ( "ID" NUMBER(18,0) DEFAULT PRISM_JOB.JOB_SEQ.NEXTVAL NOT NULL ENABLE, kafka-connect | "NAME" VARCHAR2(100) NOT NULL ENABLE kafka-connect | ) ;, tables=[columns: { kafka-connect | ID NUMBER(18, 0) NOT NULL DEFAULT VALUE PRISM_JOB.JOB_SEQ.NEXTVAL kafka-connect | NAME VARCHAR2(100) NOT NULL kafka-connect | } kafka-connect | primary key: [] kafka-connect | default charset: null kafka-connect | ], type=CREATE] (io.debezium.connector.oracle.OracleDatabaseSchema:67) kafka-connect | [2021-10-27 19:35:54,600] DEBUG [source-oracle-dbz-xstream-00|task-0] Mapping table 'ORCLPDB1.PRISM_JOB.JOB' to schemas under 'asgard.PRISM_JOB.JOB' (io.debezium.relational.TableSchemaBuilder:103) kafka-connect | [2021-10-27 19:35:54,601] DEBUG [source-oracle-dbz-xstream-00|task-0] Building schema for column ID of type 2 named NUMBER with constraints (18,Optional[0]) (io.debezium.connector.oracle.OracleValueConverters:116) kafka-connect | [2021-10-27 19:35:54,602] ERROR [source-oracle-dbz-xstream-00|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:31) kafka-connect | org.apache.kafka.connect.errors.SchemaBuilderException: Invalid default value kafka-connect | at org.apache.kafka.connect.data.SchemaBuilder.defaultValue(SchemaBuilder.java:131) kafka-connect | at io.debezium.relational.TableSchemaBuilder.addField(TableSchemaBuilder.java:374) kafka-connect | at io.debezium.relational.TableSchemaBuilder.lambda$create$2(TableSchemaBuilder.java:119) kafka-connect | at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184) kafka-connect | at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175) kafka-connect | at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1382) kafka-connect | at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) kafka-connect | at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) kafka-connect | at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151) kafka-connect | at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174) kafka-connect | at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) kafka-connect | at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:418) kafka-connect | at io.debezium.relational.TableSchemaBuilder.create(TableSchemaBuilder.java:117) kafka-connect | at io.debezium.relational.RelationalDatabaseSchema.buildAndRegisterSchema(RelationalDatabaseSchema.java:135) kafka-connect | at io.debezium.connector.oracle.OracleDatabaseSchema.lambda$applySchemaChange$0(OracleDatabaseSchema.java:73) kafka-connect | at java.lang.Iterable.forEach(Iterable.java:75) kafka-connect | at io.debezium.connector.oracle.OracleDatabaseSchema.applySchemaChange(OracleDatabaseSchema.java:72) kafka-connect | at io.debezium.pipeline.EventDispatcher$SchemaChangeEventReceiver.schemaChangeEvent(EventDispatcher.java:539) kafka-connect | at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:119) kafka-connect | at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:305) kafka-connect | at io.debezium.connector.oracle.xstream.LcrEventHandler.dispatchDataChangeEvent(LcrEventHandler.java:161) kafka-connect | at io.debezium.connector.oracle.xstream.LcrEventHandler.processRowLCR(LcrEventHandler.java:143) kafka-connect | at io.debezium.connector.oracle.xstream.LcrEventHandler.processLCR(LcrEventHandler.java:111) kafka-connect | at oracle.streams.XStreamOut.XStreamOutReceiveLCRCallbackNative(Native Method) kafka-connect | at oracle.streams.XStreamOut.receiveLCRCallback(XStreamOut.java:465) kafka-connect | at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:108) kafka-connect | at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:43) kafka-connect | at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:166) kafka-connect | at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) kafka-connect | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) kafka-connect | at java.util.concurrent.FutureTask.run(FutureTask.java:266) kafka-connect | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) kafka-connect | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) kafka-connect | at java.lang.Thread.run(Thread.java:748) kafka-connect | Caused by: org.apache.kafka.connect.errors.DataException: Invalid Java object for schema type INT64: class java.lang.String for field: "null" kafka-connect | at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:240) kafka-connect | at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:213) kafka-connect | at org.apache.kafka.connect.data.SchemaBuilder.defaultValue(SchemaBuilder.java:129) kafka-connect | ... 33 more kafka-connect | [2021-10-27 19:35:54,610] DEBUG [source-oracle-dbz-xstream-00|task-0] Processing DML event DefaultRowLCR: kafka-connect | Header: kafka-connect | source database name: ORCLPDB1 kafka-connect | command type: COMMIT kafka-connect | object owner: kafka-connect | object name: kafka-connect | tag: [] kafka-connect | position: [0 0 0 0 0 37 ffffffb2 ffffffaf 0 0 0 1 0 0 0 1 0 0 0 0 0 37 ffffffb2 ffffffaf 0 0 0 1 0 0 0 1 2] kafka-connect | transaction id: 1.26.721 kafka-connect | source time: 2021-10-27 19:35:50 kafka-connect | scn: null kafka-connect | commit scn: null kafka-connect | lcr flags: kafka-connect | Statement LCR: false kafka-connect | IDKeyColumnsOnly LCR: false kafka-connect | Sequence LCR: false kafka-connect | Attribute[0] kafka-connect | Old column values (0): kafka-connect | New column values (0): kafka-connect | (io.debezium.connector.oracle.xstream.LcrEventHandler:148) kafka-connect | [2021-10-27 19:35:55,075] DEBUG [source-oracle-dbz-xstream-00|task-0] checking for more records... (io.debezium.connector.base.ChangeEventQueue:251) kafka-connect | [2021-10-27 19:35:55,076] DEBUG [source-oracle-dbz-xstream-00|task-0] polling records... (io.debezium.connector.base.ChangeEventQueue:234) kafka-connect | [2021-10-27 19:35:55,076] INFO [source-oracle-dbz-xstream-00|task-0] WorkerSourceTask{id=source-oracle-dbz-xstream-00-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask:424) kafka-connect | [2021-10-27 19:35:55,077] INFO [source-oracle-dbz-xstream-00|task-0] WorkerSourceTask{id=source-oracle-dbz-xstream-00-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:441) kafka-connect | [2021-10-27 19:35:55,077] ERROR [source-oracle-dbz-xstream-00|task-0] WorkerSourceTask{id=source-oracle-dbz-xstream-00-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:186) kafka-connect | org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. kafka-connect | at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) kafka-connect | at io.debezium.connector.oracle.xstream.LcrEventHandler.processLCR(LcrEventHandler.java:124) kafka-connect | at oracle.streams.XStreamOut.XStreamOutReceiveLCRCallbackNative(Native Method) kafka-connect | at oracle.streams.XStreamOut.receiveLCRCallback(XStreamOut.java:465) kafka-connect | at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:108) kafka-connect | at io.debezium.connector.oracle.xstream.XstreamStreamingChangeEventSource.execute(XstreamStreamingChangeEventSource.java:43) kafka-connect | at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:166) kafka-connect | at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) kafka-connect | at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) kafka-connect | at java.util.concurrent.FutureTask.run(FutureTask.java:266) kafka-connect | at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) kafka-connect | at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) kafka-connect | at java.lang.Thread.run(Thread.java:748) kafka-connect | Caused by: org.apache.kafka.connect.errors.SchemaBuilderException: Invalid default value kafka-connect | at org.apache.kafka.connect.data.SchemaBuilder.defaultValue(SchemaBuilder.java:131) kafka-connect | at io.debezium.relational.TableSchemaBuilder.addField(TableSchemaBuilder.java:374) kafka-connect | at io.debezium.relational.TableSchemaBuilder.lambda$create$2(TableSchemaBuilder.java:119) kafka-connect | at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:184) kafka-connect | at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175) kafka-connect | at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1382) kafka-connect | at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482) kafka-connect | at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472) kafka-connect | at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:151) kafka-connect | at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:174) kafka-connect | at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) kafka-connect | at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:418) kafka-connect | at io.debezium.relational.TableSchemaBuilder.create(TableSchemaBuilder.java:117) kafka-connect | at io.debezium.relational.RelationalDatabaseSchema.buildAndRegisterSchema(RelationalDatabaseSchema.java:135) kafka-connect | at io.debezium.connector.oracle.OracleDatabaseSchema.lambda$applySchemaChange$0(OracleDatabaseSchema.java:73) kafka-connect | at java.lang.Iterable.forEach(Iterable.java:75) kafka-connect | at io.debezium.connector.oracle.OracleDatabaseSchema.applySchemaChange(OracleDatabaseSchema.java:72) kafka-connect | at io.debezium.pipeline.EventDispatcher$SchemaChangeEventReceiver.schemaChangeEvent(EventDispatcher.java:539) kafka-connect | at io.debezium.connector.oracle.OracleSchemaChangeEventEmitter.emitSchemaChangeEvent(OracleSchemaChangeEventEmitter.java:119) kafka-connect | at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:305) kafka-connect | at io.debezium.connector.oracle.xstream.LcrEventHandler.dispatchDataChangeEvent(LcrEventHandler.java:161) kafka-connect | at io.debezium.connector.oracle.xstream.LcrEventHandler.processRowLCR(LcrEventHandler.java:143) kafka-connect | at io.debezium.connector.oracle.xstream.LcrEventHandler.processLCR(LcrEventHandler.java:111) kafka-connect | ... 11 more kafka-connect | Caused by: org.apache.kafka.connect.errors.DataException: Invalid Java object for schema type INT64: class java.lang.String for field: "null" kafka-connect | at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:240) kafka-connect | at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:213) kafka-connect | at org.apache.kafka.connect.data.SchemaBuilder.defaultValue(SchemaBuilder.java:129) kafka-connect | ... 33 more kafka-connect | [2021-10-27 19:35:55,078] ERROR [source-oracle-dbz-xstream-00|task-0] WorkerSourceTask{id=source-oracle-dbz-xstream-00-0} Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:187) kafka-connect | [2021-10-27 19:35:55,078] INFO [source-oracle-dbz-xstream-00|task-0] Stopping down connector (io.debezium.connector.common.BaseSourceTask:241) kafka-connect | [2021-10-27 19:35:55,278] INFO [source-oracle-dbz-xstream-00|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965) kafka-connect | [2021-10-27 19:35:55,279] INFO [source-oracle-dbz-xstream-00|task-0] Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:167) kafka-connect | [2021-10-27 19:35:55,279] INFO [source-oracle-dbz-xstream-00|task-0] Connected metrics set to 'false' (io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics:70)