In order to make your issue reports as actionable as possible, please provide the following information, depending on the issue type.

Bug report

For bug reports, provide this information, please:

What Debezium connector do you use and what version?

1.9.7.Final

What is the connector configuration?

"config":

{ "connector.class": "io.debezium.connector.mysql.MySqlConnector", "database.hostname": "$url", "database.user": "$user", "database.password": "$password", "database.server.id": "184058", "database.server.name": "debezium_as_vehicle", "database.include.list": "as_vehicle", "table.include.list": "as_vehicle.vehicle_activity,as_vehicle.vehicle_activity_0,as_vehicle.vehicle_activity_1,as_vehicle.vehicle_activity_2,as_vehicle.vehicle_activity_3,as_vehicle.vehicle_activity_4,as_vehicle.vehicle_activity_5,as_vehicle.vehicle_activity_6,as_vehicle.vehicle_activity_7,as_vehicle.vehicle_activity_8,as_vehicle.vehicle_activity_9,as_vehicle.vehicle_activity_10,as_vehicle.vehicle_activity_11,as_vehicle.vehicle_activity_12,as_vehicle.vehicle_activity_13,as_vehicle.vehicle_activity_14,as_vehicle.vehicle_activity_15,as_vehicle.vehicle_activity_16,as_vehicle.vehicle_activity_17,as_vehicle.vehicle_activity_18,as_vehicle.vehicle_activity_19,as_vehicle.vehicle_customer,as_vehicle.vehicle_customer_0,as_vehicle.vehicle_customer_1,as_vehicle.vehicle_customer_2,as_vehicle.vehicle_customer_3,as_vehicle.vehicle_customer_4,as_vehicle.vehicle_customer_5,as_vehicle.vehicle_customer_6,as_vehicle.vehicle_customer_7,as_vehicle.vehicle_customer_8,as_vehicle.vehicle_customer_9,as_vehicle.vehicle_customer_10,as_vehicle.vehicle_customer_11,as_vehicle.vehicle_customer_12,as_vehicle.vehicle_customer_13,as_vehicle.vehicle_customer_14,as_vehicle.vehicle_customer_15,as_vehicle.vehicle_customer_16,as_vehicle.vehicle_customer_17,as_vehicle.vehicle_customer_18,as_vehicle.vehicle_customer_19,as_vehicle.vehicle_info,as_vehicle.vehicle_info_0,as_vehicle.vehicle_info_1,as_vehicle.vehicle_info_2,as_vehicle.vehicle_info_3,as_vehicle.vehicle_info_4,as_vehicle.vehicle_info_5,as_vehicle.vehicle_info_6,as_vehicle.vehicle_info_7,as_vehicle.vehicle_info_8,as_vehicle.vehicle_info_9,as_vehicle.vehicle_pwei,as_vehicle.vehicle_pwei_0,as_vehicle.vehicle_pwei_1,as_vehicle.vehicle_pwei_2,as_vehicle.vehicle_pwei_3,as_vehicle.vehicle_pwei_4,as_vehicle.vehicle_pwei_5,as_vehicle.vehicle_pwei_6,as_vehicle.vehicle_pwei_7,as_vehicle.vehicle_pwei_8,as_vehicle.vehicle_pwei_9,as_vehicle.vehicle_pwei_10,as_vehicle.vehicle_pwei_11,as_vehicle.vehicle_pwei_12,as_vehicle.vehicle_pwei_13,as_vehicle.vehicle_pwei_14,as_vehicle.vehicle_pwei_15,as_vehicle.vehicle_pwei_16,as_vehicle.vehicle_pwei_17,as_vehicle.vehicle_pwei_18,as_vehicle.vehicle_pwei_19,as_vehicle.vehicle_pwei_20,as_vehicle.vehicle_pwei_21,as_vehicle.vehicle_pwei_22,as_vehicle.vehicle_pwei_23,as_vehicle.vehicle_pwei_24,as_vehicle.vehicle_pwei_25,as_vehicle.vehicle_pwei_26,as_vehicle.vehicle_pwei_27,as_vehicle.vehicle_pwei_28,as_vehicle.vehicle_pwei_29,as_vehicle.debezium_signal", "database.history.kafka.bootstrap.servers": "$kafka_servers", "database.history.kafka.topic": "debezium_as_vehicle.as_vehicle", "include.schema.changes": "false", "database.ssl.mode": "preferred", "database.connectionTimeZone": "UTC", "snapshot.fetch.size": 1024, "offset.flush.timeout.ms": 300000, "key.converter": "org.apache.kafka.connect.json.JsonConverter", "value.converter": "org.apache.kafka.connect.json.JsonConverter", "key.converter.schemas.enable": "false", "value.converter.schemas.enable": "false", "transforms": "unwrap,rerouteActivity,rerouteCustomer,rerouteInfo,reroutePwei", "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState", "transforms.unwrap.add.fields": "op,table", "transforms.unwrap.add.headers": "db", "transforms.unwrap.delete.handling.mode": "rewrite", "transforms.rerouteActivity.type": "io.debezium.transforms.ByLogicalTableRouter", "transforms.rerouteActivity.topic.regex": "(.*)as_vehicle.vehicle_activity(.*)", "transforms.rerouteActivity.topic.replacement":"$1as_vehicle_dbzone.vehicle_activity_all_shards", "transforms.rerouteCustomer.type": "io.debezium.transforms.ByLogicalTableRouter", "transforms.rerouteCustomer.topic.regex": "(.*)as_vehicle.vehicle_customer(.*)", "transforms.rerouteCustomer.topic.replacement":"$1as_vehicle_dbzone.vehicle_customer_all_shards", "transforms.rerouteInfo.type": "io.debezium.transforms.ByLogicalTableRouter", "transforms.rerouteInfo.topic.regex": "(.*)as_vehicle.vehicle_info(.*)", "transforms.rerouteInfo.topic.replacement":"$1as_vehicle_dbzone.vehicle_info_all_shards", "transforms.reroutePwei.type": "io.debezium.transforms.ByLogicalTableRouter", "transforms.reroutePwei.topic.regex": "(.*)as_vehicle.vehicle_pwei(.*)", "transforms.reroutePwei.topic.replacement":"$1as_vehicle_dbzone.vehicle_pwei_all_shards", "snapshot.mode": "schema_only", "signal.data.collection": "as_vehicle.debezium_signal", "decimal.handling.mode": "string" }

 

table: 

create table vehicle_activity
(
id bigint auto_increment
primary key,
dealer_id varchar(50) not null,
operator_id varchar(50) null,
vehicle_prod_id bigint null,
vehicle_info_id bigint null,
activity_type varchar(100) null,
created_time datetime default CURRENT_TIMESTAMP null
);

 

create table vehicle_activity_xx
(
id bigint auto_increment
primary key,
dealer_id varchar(50) not null,
operator_id varchar(50) null,
vehicle_prod_id bigint null,
vehicle_info_id bigint null,
activity_type varchar(100) null,
created_time datetime default CURRENT_TIMESTAMP null
);

What is the captured database version and mode of depoyment?

Azure Mysql 5.7

What behaviour do you expect?

N/A

What behaviour do you see?

N/A

Do you see the same behaviour using the latest relesead Debezium version?

(Ideally, also verify with latest Alpha/Beta/CR version)

1.9.7.Final

Do you have the connector logs, ideally from start till finish?

(You might be asked later to provide DEBUG/TRACE level log)

error trace:
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.\n\tat io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:50)\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:374)\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$25(MySqlStreamingChangeEventSource.java:874)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1246)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1072)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:631)\n\tat com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:932)\n\tat java.lang.Thread.run(Thread.java:748)\nCaused by: io.debezium.DebeziumException: Error processing binlog event\n\t... 7 more\nCaused by: org.apache.kafka.connect.errors.ConnectException: Error while processing event at offset {transaction_id=null, ts_sec=1667509273, file=mysql-bin.001206, pos=70419533, incremental_snapshot_maximum_key=aced0005757200135b4c6a6176612e6c616e672e4f626a6563743b90ce589f1073296c0200007870000000017372000e6a6176612e6c616e672e4c6f6e673b8be490cc8f23df0200014a000576616c7565787200106a6176612e6c616e672e4e756d62657286ac951d0b94e08b02000078700000000002d9fe24, row=1, server_id=3530210693, event=2, incremental_snapshot_collections=as_vehicle.vehicle_activity,as_vehicle.vehicle_activity_0,as_vehicle.vehicle_activity_1,as_vehicle.vehicle_activity_2,as_vehicle.vehicle_activity_3,as_vehicle.vehicle_activity_4,as_vehicle.vehicle_activity_5,as_vehicle.vehicle_activity_6,as_vehicle.vehicle_activity_7,as_vehicle.vehicle_activity_8,as_vehicle.vehicle_activity_9,as_vehicle.vehicle_activity_10,as_vehicle.vehicle_activity_11,as_vehicle.vehicle_activity_12,as_vehicle.vehicle_activity_13,as_vehicle.vehicle_activity_14,as_vehicle.vehicle_activity_15,as_vehicle.vehicle_activity_16,as_vehicle.vehicle_activity_17,as_vehicle.vehicle_activity_18,as_vehicle.vehicle_activity_19,as_vehicle.vehicle_customer,as_vehicle.vehicle_customer_0,as_vehicle.vehicle_customer_1,as_vehicle.vehicle_customer_2,as_vehicle.vehicle_customer_3,as_vehicle.vehicle_customer_4,as_vehicle.vehicle_customer_5,as_vehicle.vehicle_customer_6,as_vehicle.vehicle_customer_7,as_vehicle.vehicle_customer_8,as_vehicle.vehicle_customer_9,as_vehicle.vehicle_customer_10,as_vehicle.vehicle_customer_11,as_vehicle.vehicle_customer_12,as_vehicle.vehicle_customer_13,as_vehicle.vehicle_customer_14,as_vehicle.vehicle_customer_15,as_vehicle.vehicle_customer_16,as_vehicle.vehicle_customer_17,as_vehicle.vehicle_customer_18,as_vehicle.vehicle_customer_19,as_vehicle.vehicle_info,as_vehicle.vehicle_info_0,as_vehicle.vehicle_info_1,as_vehicle.vehicle_info_2,as_vehicle.vehicle_info_3,as_vehicle.vehicle_info_4,as_vehicle.vehicle_info_5,as_vehicle.vehicle_info_6,as_vehicle.vehicle_info_7,as_vehicle.vehicle_info_8,as_vehicle.vehicle_info_9,as_vehicle.vehicle_pwei,as_vehicle.vehicle_pwei_0,as_vehicle.vehicle_pwei_1,as_vehicle.vehicle_pwei_2,as_vehicle.vehicle_pwei_3,as_vehicle.vehicle_pwei_4,as_vehicle.vehicle_pwei_5,as_vehicle.vehicle_pwei_6,as_vehicle.vehicle_pwei_7,as_vehicle.vehicle_pwei_8,as_vehicle.vehicle_pwei_9,as_vehicle.vehicle_pwei_10,as_vehicle.vehicle_pwei_11,as_vehicle.vehicle_pwei_12,as_vehicle.vehicle_pwei_13,as_vehicle.vehicle_pwei_14,as_vehicle.vehicle_pwei_15,as_vehicle.vehicle_pwei_16,as_vehicle.vehicle_pwei_17,as_vehicle.vehicle_pwei_18,as_vehicle.vehicle_pwei_19,as_vehicle.vehicle_pwei_20,as_vehicle.vehicle_pwei_21,as_vehicle.vehicle_pwei_22,as_vehicle.vehicle_pwei_23,as_vehicle.vehicle_pwei_24,as_vehicle.vehicle_pwei_25,as_vehicle.vehicle_pwei_26,as_vehicle.vehicle_pwei_27,as_vehicle.vehicle_pwei_28,as_vehicle.vehicle_pwei_29, incremental_snapshot_primary_key=aced0005757200135b4c6a6176612e6c616e672e4f626a6563743b90ce589f1073296c0200007870000000017372000e6a6176612e6c616e672e4c6f6e673b8be490cc8f23df0200014a000576616c7565787200106a6176612e6c616e672e4e756d62657286ac951d0b94e08b02000078700000000000eaac00}\n\tat io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:246)\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$handleUpdate$6(MySqlStreamingChangeEventSource.java:718)\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleChange(MySqlStreamingChangeEventSource.java:762)\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleUpdate(MySqlStreamingChangeEventSource.java:716)\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$18(MySqlStreamingChangeEventSource.java:855)\n\tat io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:354)\n\t... 6 more\nCaused by: java.lang.IllegalArgumentException: Unexpected value for JDBC type -5 and column id BIGINT(20) NOT NULL AUTO_INCREMENTED GENERATED: class=class [B\n\tat io.debezium.jdbc.JdbcValueConverters.handleUnknownData(JdbcValueConverters.java:1257)\n\tat io.debezium.jdbc.JdbcValueConverters.convertValue(JdbcValueConverters.java:1300)\n\tat io.debezium.jdbc.JdbcValueConverters.convertBigInt(JdbcValueConverters.java:916)\n\tat io.debezium.connector.mysql.MySqlValueConverters.convertBigInt(MySqlValueConverters.java:410)\n\tat io.debezium.jdbc.JdbcValueConverters.lambda$converter$6(JdbcValueConverters.java:297)\n\tat io.debezium.relational.TableSchemaBuilder.lambda$createKeyGenerator$3(TableSchemaBuilder.java:224)\n\tat io.debezium.relational.TableSchema.keyFromColumnData(TableSchema.java:130)\n\tat io.debezium.relational.RelationalChangeRecordEmitter.emitUpdateRecord(RelationalChangeRecordEmitter.java:100)\n\tat io.debezium.relational.RelationalChangeRecordEmitter.emitChangeRecords(RelationalChangeRecordEmitter.java:53)\n\tat io.debezium.pipeline.EventDispatcher.dispatchDataChangeEvent(EventDispatcher.java:209)\n\t... 11 more\n"