Getting "Unexpected value for JDBC type 4 error" for INSERT event

[Vivek Kumar]

Hi Team,

We're getting the below mentioned issue while processing an INSERT event and it is working fine if we restart the debezium service :

connect.log.2024-07-31-17-org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
connect.log.2024-07-31-17- at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:67)
connect.log.2024-07-31-17- at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:393)
connect.log.2024-07-31-17- at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$27(MySqlStreamingChangeEventSource.java:928)
connect.log.2024-07-31-17- at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1246)
connect.log.2024-07-31-17- at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1072)
connect.log.2024-07-31-17- at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:631)
connect.log.2024-07-31-17- at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:932)
connect.log.2024-07-31-17- at java.base/java.lang.Thread.run(Thread.java:840)
connect.log.2024-07-31-17-Caused by: io.debezium.DebeziumException: Error processing binlog event
connect.log.2024-07-31-17- ... 7 more
connect.log.2024-07-31-17-Caused by: org.apache.kafka.connect.errors.ConnectException: Error while processing event at offset {transaction_id=file=mysql-bin-changelog.112782,pos=168977, ts_sec=1722445541, file=mysql-bin-changelog.112782, pos=168977, row=1, server_id=2090513544, event=10, transaction_data_collection_order_unicorn.address=1}
connect.log.2024-07-31-17- at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:339)
connect.log.2024-07-31-17- at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$handleInsert$5(MySqlStreamingChangeEventSource.java:752)
connect.log.2024-07-31-17- at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleChange(MySqlStreamingChangeEventSource.java:811)
connect.log.2024-07-31-17- at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleInsert(MySqlStreamingChangeEventSource.java:750)
connect.log.2024-07-31-17- at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$18(MySqlStreamingChangeEventSource.java:904)
connect.log.2024-07-31-17- at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:373)
connect.log.2024-07-31-17- ... 6 more
connect.log.2024-07-31-17-Caused by: java.lang.IllegalArgumentException: Unexpected value for JDBC type 4 and column id INT(11) NOT NULL AUTO_INCREMENTED GENERATED: class=byte[]
connect.log.2024-07-31-17- at io.debezium.jdbc.JdbcValueConverters.handleUnknownData(JdbcValueConverters.java:1290)
connect.log.2024-07-31-17- at io.debezium.jdbc.JdbcValueConverters.convertValue(JdbcValueConverters.java:1334)
connect.log.2024-07-31-17- at io.debezium.jdbc.JdbcValueConverters.convertInteger(JdbcValueConverters.java:922)
connect.log.2024-07-31-17- at io.debezium.connector.mysql.MySqlValueConverters.convertInteger(MySqlValueConverters.java:405)
connect.log.2024-07-31-17- at io.debezium.jdbc.JdbcValueConverters.lambda$converter$5(JdbcValueConverters.java:296)
connect.log.2024-07-31-17- at io.debezium.relational.TableSchemaBuilder.lambda$createKeyGenerator$3(TableSchemaBuilder.java:205)
connect.log.2024-07-31-17- at io.debezium.relational.TableSchema.keyFromColumnData(TableSchema.java:130)
connect.log.2024-07-31-17- at io.debezium.relational.RelationalChangeRecordEmitter.emitCreateRecord(RelationalChangeRecordEmitter.java:70)
connect.log.2024-07-31-17- at io.debezium.relational.RelationalChangeRecordEmitter.emitChangeRecords(RelationalChangeRecordEmitter.java:47)
connect.log.2024-07-31-17- at io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:296)
connect.log.2024-07-31-17- ... 11 more

Thanks.

PROPRIETARY / CONFIDENTIALITY NOTICE

This message (including any attachments) contains information that is proprietary and confidential to PRIORITY TECHNOLOGY HOLDINGS, INC. and its affiliates and subsidiaries, including the sender hereof, and is for the sole use of the intended recipients. If you are not an intended recipient, you may not read, print, retain, use, copy, distribute, forward or disclose to anyone this message or any information contained in this message (including any attachments). If you have received this message in error, please advise the sender of this error by reply e-mail, and please destroy all copies of this message (including any attachments).

[jiri.p...@gmail.com]

Hi,

could you please try to enable TRACE level logging for io.debezium.jdbc.JdbcValueConverters?

Jiri