-
Bug
-
Resolution: Done
-
Blocker
-
1.6.1.Final
-
None
-
False
-
False
-
undefined
-
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" }