Details
-
Bug
-
Resolution: Obsolete
-
Major
-
None
-
0.9.5.Final
-
None
Description
When running the script, Debezium goes into failed state with error:
org.apache.kafka.connect.errors.ConnectException: Invalid default value\n\tat io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)\n\tat io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:208)\n\tat io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:508)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1095)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:943)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:580)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:825)\n\tat java.lang.Thread.run(Thread.java:748)\nCaused by: org.apache.kafka.connect.errors.SchemaBuilderException: Invalid default value\n\tat org.apache.kafka.connect.data.SchemaBuilder.defaultValue(SchemaBuilder.java:131)\n\tat io.debezium.relational.TableSchemaBuilder.addField(TableSchemaBuilder.java:346)\n\tat io.debezium.relational.TableSchemaBuilder.lambda$create$0(TableSchemaBuilder.java:106)\n\tat java.util.ArrayList.forEach(ArrayList.java:1257)\n\tat java.util.Collections$UnmodifiableCollection.forEach(Collections.java:1080)\n\tat java.util.Collections$UnmodifiableCollection.forEach(Collections.java:1080)\n\tat io.debezium.relational.TableSchemaBuilder.create(TableSchemaBuilder.java:97)\n\tat io.debezium.relational.RelationalDatabaseSchema.buildAndRegisterSchema(RelationalDatabaseSchema.java:117)\n\tat io.debezium.connector.mysql.MySqlSchema.lambda$applyDdl$4(MySqlSchema.java:374)\n\tat java.lang.Iterable.forEach(Iterable.java:75)\n\tat io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:368)\n\tat io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:694)\n\tat io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:492)\n\t... 5 more\nCaused by: org.apache.kafka.connect.errors.DataException: Invalid value: null used for required field: \"null\", schema type: STRING\n\tat org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:220)\n\tat org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:213)\n\tat org.apache.kafka.connect.data.SchemaBuilder.defaultValue(SchemaBuilder.java:129)\n\t... 17 more\n
