Details
-
Bug
-
Resolution: Done
-
Blocker
-
1.6.1.Final
-
None
-
False
-
False
-
undefined
Description
trace:
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource$ReaderThreadLifecycleListener.onEventDeserializationFailure(MySqlStreamingChangeEventSource.java:1207) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:958) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:606) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:850) at java.lang.Thread.run(Thread.java:745) Caused by: io.debezium.DebeziumException at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.wrap(MySqlStreamingChangeEventSource.java:1154) ... 5 more Caused by: java.lang.ArrayIndexOutOfBoundsException at com.github.shyiko.mysql.binlog.io.BufferedSocketInputStream.read(BufferedSocketInputStream.java:65) at com.github.shyiko.mysql.binlog.io.ByteArrayInputStream.readWithinBlockBoundaries(ByteArrayInputStream.java:262) at com.github.shyiko.mysql.binlog.io.ByteArrayInputStream.read(ByteArrayInputStream.java:241) at java.io.InputStream.skip(InputStream.java:224) at com.github.shyiko.mysql.binlog.io.ByteArrayInputStream.skipToTheEndOfTheBlock(ByteArrayInputStream.java:280) at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeEventData(EventDeserializer.java:305) at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.nextEvent(EventDeserializer.java:232) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource$1.nextEvent(MySqlStreamingChangeEventSource.java:230) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:945) ... 3 more
connector config:
{
"snapshot.locking.mode": "none",
"connector.class": "io.debezium.connector.mysql.MySqlConnector",
"transforms.Reroute.type": "io.debezium.transforms.ByLogicalTableRouter",
"database.user": "rep",
"tasks.max": "1",
"database.history.kafka.bootstrap.servers": xxx,
"database.useCursorFetch": "true",
"transforms": "Reroute",
"database.server.name": "088-XIMA_UCP-UCP_USER_COUPON-33",
"transforms.Reroute.topic.regex": "(.*)XIMA_UCP_\\d+\\.UCP_USER_COUPON_\\d+",
"debezium.snapshot.new.tables": "parallel",
"database.port": "3306",
"transforms.Reroute.topic.replacement": "rowdata-XIMA_UCP-UCP_USER_COUPON-2",
"min.row.count.to.stream.results": "0",
"database.hostname": xxxx,
"database.password": xxxx,
"name": "088-XIMA_UCP-UCP_USER_COUPON-33",
"table.include.list": "XIMA_UCP_\\d+\\.UCP_USER_COUPON_\\d+",
"snapshot.fetch.size": "5000",
"database.include.list": "XIMA_UCP_\\d+",
"snapshot.mode": "when_needed"
}