Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-3848

Connector throws java.lang.ArrayIndexOutOfBoundsException

XMLWordPrintable

      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"
      }
      

        1. binlog.sample
          13 kB
        2. trace.log
          11.56 MB

            Unassigned Unassigned
            cosimozi 子悠 徐 (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

              Created:
              Updated:
              Resolved: