[2022-04-13 14:29:45,363] DEBUG Applying schema change event SchemaChangeEvent [database=*******, schema=***, ddl=null, tables=[columns: { kafka-connect | VTAR# CHAR(36) NOT NULL kafka-connect | PSCHABL# CHAR(36) NOT NULL kafka-connect | GEWINNVERBAND CHAR(7) NOT NULL DEFAULT VALUE ' ' kafka-connect | VERWENDTYP CHAR(1) NOT NULL DEFAULT VALUE ' ' kafka-connect | PROVTARIFGRP CHAR(2) NOT NULL DEFAULT VALUE ' ' kafka-connect | GILTAB DATE(10) NOT NULL DEFAULT VALUE '0001-01-01' kafka-connect | GILTBIS DATE(10) NOT NULL DEFAULT VALUE '0001-01-01' kafka-connect | } kafka-connect | primary key: [VTAR#, PSCHABL#] kafka-connect | default charset: null kafka-connect | comment: null kafka-connect | ], type=CREATE] (io.debezium.connector.db2.Db2DatabaseSchema) kafka-connect | [2022-04-13 14:29:45,363] DEBUG Mapping table '***.' to schemas under '***.***.' (io.debezium.relational.TableSchemaBuilder) kafka-connect | [2022-04-13 14:29:45,363] DEBUG - field 'VTAR#' (STRING) from column VTAR# CHAR(36) NOT NULL (io.debezium.relational.TableSchemaBuilder) kafka-connect | [2022-04-13 14:29:45,364] DEBUG - field 'PSCHABL#' (STRING) from column PSCHABL# CHAR(36) NOT NULL (io.debezium.relational.TableSchemaBuilder) kafka-connect | [2022-04-13 14:29:45,364] DEBUG - field 'VTAR#' (STRING) from column VTAR# CHAR(36) NOT NULL (io.debezium.relational.TableSchemaBuilder) kafka-connect | [2022-04-13 14:29:45,364] DEBUG - field 'PSCHABL#' (STRING) from column PSCHABL# CHAR(36) NOT NULL (io.debezium.relational.TableSchemaBuilder) kafka-connect | [2022-04-13 14:29:45,364] DEBUG - field 'GEWINNVERBAND' (STRING) from column GEWINNVERBAND CHAR(7) NOT NULL DEFAULT VALUE ' ' (io.debezium.relational.TableSchemaBuilder) kafka-connect | [2022-04-13 14:29:45,364] DEBUG - field 'VERWENDTYP' (STRING) from column VERWENDTYP CHAR(1) NOT NULL DEFAULT VALUE ' ' (io.debezium.relational.TableSchemaBuilder) kafka-connect | [2022-04-13 14:29:45,364] DEBUG - field 'PROVTARIFGRP' (STRING) from column PROVTARIFGRP CHAR(2) NOT NULL DEFAULT VALUE ' ' (io.debezium.relational.TableSchemaBuilder) kafka-connect | [2022-04-13 14:29:45,477] INFO Snapshot - Final stage (io.debezium.pipeline.source.AbstractSnapshotChangeEventSource) kafka-connect | [2022-04-13 14:29:45,477] ERROR Producer failure (io.debezium.pipeline.ErrorHandler) kafka-connect | io.debezium.DebeziumException: io.debezium.DebeziumException: org.apache.kafka.connect.errors.SchemaBuilderException: Invalid default value kafka-connect | at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:85) kafka-connect | at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:155) kafka-connect | at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:137) kafka-connect | at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) kafka-connect | at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) kafka-connect | at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) kafka-connect | at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) kafka-connect | at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) kafka-connect | at java.base/java.lang.Thread.run(Thread.java:829) kafka-connect | Caused by: io.debezium.DebeziumException: org.apache.kafka.connect.errors.SchemaBuilderException: Invalid default value kafka-connect | at io.debezium.relational.RelationalSnapshotChangeEventSource.lambda$createSchemaChangeEventsForTables$2(RelationalSnapshotChangeEventSource.java:280) kafka-connect | at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:310) kafka-connect | at io.debezium.relational.RelationalSnapshotChangeEventSource.createSchemaChangeEventsForTables(RelationalSnapshotChangeEventSource.java:275) kafka-connect | at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:118) kafka-connect | at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76) kafka-connect | ... 8 more 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:412) kafka-connect | at io.debezium.relational.TableSchemaBuilder.lambda$create$2(TableSchemaBuilder.java:147) kafka-connect | at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) kafka-connect | at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:177) kafka-connect | at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655) kafka-connect | at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) kafka-connect | at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) kafka-connect | at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) kafka-connect | at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) kafka-connect | at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) kafka-connect | at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497) kafka-connect | at io.debezium.relational.TableSchemaBuilder.create(TableSchemaBuilder.java:145) kafka-connect | at io.debezium.relational.RelationalDatabaseSchema.buildAndRegisterSchema(RelationalDatabaseSchema.java:135) kafka-connect | at io.debezium.connector.db2.Db2DatabaseSchema.applySchemaChange(Db2DatabaseSchema.java:49) kafka-connect | at io.debezium.pipeline.EventDispatcher$SchemaChangeEventReceiver.schemaChangeEvent(EventDispatcher.java:547) kafka-connect | at io.debezium.relational.RelationalSnapshotChangeEventSource.lambda$createSchemaChangeEventsForTables$2(RelationalSnapshotChangeEventSource.java:277) kafka-connect | ... 12 more kafka-connect | Caused by: org.apache.kafka.connect.errors.DataException: Invalid Java object for schema "io.debezium.time.Date" with type INT32: class java.lang.String kafka-connect | at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:242) 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 | ... 28 more kafka-connect | [2022-04-13 14:29:45,477] INFO Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator) kafka-connect | [2022-04-13 14:29:45,766] DEBUG checking for more records... (io.debezium.connector.base.ChangeEventQueue) kafka-connect | [2022-04-13 14:29:45,766] INFO WorkerSourceTask{id=db2-connector-5-0} Either no records were produced by the task since the last offset commit, or every record has been filtered out by a transformation or dropped due to transformation or conversion errors. (org.apache.kafka.connect.runtime.WorkerSourceTask) kafka-connect | [2022-04-13 14:29:45,766] ERROR WorkerSourceTask{id=db2-connector-5-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask) 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:50) kafka-connect | at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:116) kafka-connect | at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) kafka-connect | at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) kafka-connect | at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) kafka-connect | at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) kafka-connect | at java.base/java.lang.Thread.run(Thread.java:829) kafka-connect | Caused by: io.debezium.DebeziumException: io.debezium.DebeziumException: org.apache.kafka.connect.errors.SchemaBuilderException: Invalid default value kafka-connect | at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:85) kafka-connect | at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:155) kafka-connect | at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:137) kafka-connect | at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109) kafka-connect | ... 5 more kafka-connect | Caused by: io.debezium.DebeziumException: org.apache.kafka.connect.errors.SchemaBuilderException: Invalid default value kafka-connect | at io.debezium.relational.RelationalSnapshotChangeEventSource.lambda$createSchemaChangeEventsForTables$2(RelationalSnapshotChangeEventSource.java:280) kafka-connect | at io.debezium.pipeline.EventDispatcher.dispatchSchemaChangeEvent(EventDispatcher.java:310) kafka-connect | at io.debezium.relational.RelationalSnapshotChangeEventSource.createSchemaChangeEventsForTables(RelationalSnapshotChangeEventSource.java:275) kafka-connect | at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:118) kafka-connect | at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76) kafka-connect | ... 8 more 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:412) kafka-connect | at io.debezium.relational.TableSchemaBuilder.lambda$create$2(TableSchemaBuilder.java:147) kafka-connect | at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183) kafka-connect | at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:177) kafka-connect | at java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655) kafka-connect | at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) kafka-connect | at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) kafka-connect | at java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150) kafka-connect | at java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173) kafka-connect | at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) kafka-connect | at java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497) kafka-connect | at io.debezium.relational.TableSchemaBuilder.create(TableSchemaBuilder.java:145) kafka-connect | at io.debezium.relational.RelationalDatabaseSchema.buildAndRegisterSchema(RelationalDatabaseSchema.java:135) kafka-connect | at io.debezium.connector.db2.Db2DatabaseSchema.applySchemaChange(Db2DatabaseSchema.java:49) kafka-connect | at io.debezium.pipeline.EventDispatcher$SchemaChangeEventReceiver.schemaChangeEvent(EventDispatcher.java:547) kafka-connect | at io.debezium.relational.RelationalSnapshotChangeEventSource.lambda$createSchemaChangeEventsForTables$2(RelationalSnapshotChangeEventSource.java:277) kafka-connect | ... 12 more kafka-connect | Caused by: org.apache.kafka.connect.errors.DataException: Invalid Java object for schema "io.debezium.time.Date" with type INT32: class java.lang.String kafka-connect | at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:242) 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 | ... 28 more