I’m getting the below error when I’m trying to dump data from MySQL table into Kafka topic. The table has a timestamp column with a default value as ‘0000-00-00 00:00:00’.
Invalid value '0000-00-00 00:00:00' stored in column
ERROR Failed to properly convert data value for 'TabName' of type DATETIME for row [2160507548, [98, 97, 99, 99, 55, 55, 101, 52, 45, 57, 48, 48, 100, 45, 52, 56, 100, 97, 45, 57, 97, 98, 102, 45, 97, 50, 56, 101, 56, 48, 99, 98, 51, 101, 53, 101], null, null, null, null, null, null, 0, null, null, null, null, null, null, null, null, null, [111, 110, 116, 105, 109, 101], null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, 0.000000, null, null, null, null, [105, 110, 100, 105, 97], [109, 117, 109, 98, 97, 105], null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, null, 0.000000, null, null, null, null, null, [99, 97, 115, 104], null, null, 0, null, 2020-03-19 11:46:56.0, null, null, 0, null, 0, 0, null, 1, null, null, null, null, null, null, 1, null, 0.0, null, [97, 108, 108], null]: (io.debezium.relational.TableSchemaBuilder) [debezium-mysqlconnector-ola_load-change-event-source-coordinator]
io.debezium.relational.TableSchemaBuilder) [debezium-mysqlconnector-ola_load-change-event-source-coordinator]
org.apache.kafka.connect.errors.DataException: Invalid Java object for schema type STRING: class java.lang.Long for field: "date_entered"
at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:241)
at org.apache.kafka.connect.data.Struct.put(Struct.java:216)
at io.debezium.relational.TableSchemaBuilder.lambda$createKeyGenerator$3(TableSchemaBuilder.java:193)
at io.debezium.relational.TableSchema.keyFromColumnData(TableSchema.java:130)
at io.debezium.relational.RelationalChangeRecordEmitter.emitReadRecord(RelationalChangeRecordEmitter.java:84)
at io.debezium.relational.RelationalChangeRecordEmitter.emitChangeRecords(RelationalChangeRecordEmitter.java:48)
at io.debezium.pipeline.EventDispatcher.dispatchSnapshotEvent(EventDispatcher.java:155)
at io.debezium.relational.RelationalSnapshotChangeEventSource.createDataEventsForTable(RelationalSnapshotChangeEventSource.java:377)
at io.debezium.relational.RelationalSnapshotChangeEventSource.createDataEvents(RelationalSnapshotChangeEventSource.java:305)
at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:138)
at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:71)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:110)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
After failing at this step it’s retrying again the data load from MySQL table and dumping into Kafka topic again and again, this is not usual behaviour, could you please help.