mysql-binlog-connector-java
mysql-binlog-connector-java copied to clipboard
MySQL Binary Log connector
version: 0.25.3 at: com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventMetadataDeserializer.java:92  In this switch-case code block,the `case ENUM_AND_SET_COLUMN_CHARSET:` statement does not end with the `break` keyword. Is this a bug, or are there other concerns?
column type : json value: `{"rollSubNo":"EBR123456789-1,EBR123456789-2,EBR123456789-3,EBR123456789-4","rollBatchNo":"CDC00000000123456789","rollFlag":true,"rollReject":true}` ```xml com.github.shyiko mysql-binlog-connector-java 0.21.0 ``` - case 1 `JsonBinary.parseAsString(value.getBytes(StandardCharsets.US_ASCII))` exception msg: `The key offset in the JSON document is 72 and is too big...
当跑2个进程时,日志报错: 
When the `BinaryLogClient` connects to a MySQL server, it's not currently possible to identify to which server it has connected. When connecting to a pool of replicas through a load...
**Connector Status URL:** curl localhost:8083/connectors/mysql-connector-db/status | jq { "name": "mysql-connector-db", "connector": { "state": "RUNNING", "worker_id": ":8083" }, "tasks": [ { "id": 0, **"state": "FAILED",** "worker_id": ":8083", "trace": "org.apache.kafka.connect.errors.ConnectException: Unknown event...
Hi, we meet a MissingTableMapEventException, the detail exception is: ``` 2018-11-08 05:53:32.089 ERROR com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException: Failed to deserialize data of EventHeaderV4{timestamp=1541626342000, eventType=EXT_DELETE_ROWS, serverId=41083490, headerLength=19, dataLength=8135, nextPosition=706863423, flags=0} at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.deserializeEventData(EventDeserializer.java:216) at com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.nextEvent(EventDeserializer.java:184)...
Some data migration is running in mysql clusters. and getting below exception. I have retry_code that is handled through onCommunicationFailure listener, and after resetting same binlog position, it is working...
**TableMapEventMetadataDeserializer.MetadataFieldType.byCode(inputStream.readInteger(1));** inputStream.readInteger(1) gives 12 and hence, field comes as null, which finally gives an NPE. MetadataFieldType enum doesn't contain a code for 12. Mysql version: 8.0.23 The Binlog replication fails,...
I am using debezium mysql connector to read bin log content. When a table has been partitioned, the binary log records the partition information as below.  I need to...
We´re using the library to listen the changes that are made in the database binlog, working in local or in the azure mysql DB without forcing the ssl there is...