mysql-binlog-connector-java
mysql-binlog-connector-java copied to clipboard
osheroff
MySQL Binary Log connector
https://dev.mysql.com/doc/relnotes/mysql/8.4/en/news-8-4-0.html According to the MySQL release notes for MySQL 8.4 they just removed a bunch of SQL commands >SQL statements removed. The following SQL statements have been removed (replacements in...
Hi, +----+----------+-----------------+ | id | t | tt | +----+----------+-----------------+ | 1 | 00:00:01 | 00:00:01.000001 | | 2 | 00:01:06 | 00:00:16.000024 | +----+----------+-----------------+ --- tt column deserialize only...
方法updateClientBinlogFilenameAndPosition和updateGtidSet等方法一样，可以被按需重写。 例如，重写该方法并添加对 binlogFileName 和 position 进行持久化。当服务宕机重启后可以从持久化中读取并继续。 例如： ``` BinaryLogClient client = new BinaryLogClient(binLogProperties.getHost(), binLogProperties.getPort(), binLogProperties.getUsername(), binLogProperties.getPassword()) { @Override private void updateClientBinlogFilenameAndPosition(Event event) { super.updateClientBinlogFilenameAndPosition(event); // 将binlogFileName和position持久化记录，在服务宕机重启后读取并继续 // （略） } };...
We have an ETL application that uses the binlog client to read from MySQL 5.7 bin logs, and it's working fine. Recently, we have deployed the same codebase under a...
 日志显示如下： insert data#remark : {"4":{"type":"专科预约","all":1,"use":0,"remain":1}} 2024-09-13 10:26:28.442 INFO 16596 --- [ Thread-2] c.p.b.binlog.AggregationListener : insert data#description : AAEASQALAAEAAAwANAQAPQAgAAMAIwADACYABAAqAAYABQEABQAADDAABQEAYWxsdXNldHlwZXJlbWFpbgzkuJPnp5HpooTnuqY=
server version: MariaDB 10.1.44 mysql-binlog-connector-java version: 0.27.2 we set max_allowed_packet = 1073741824 in MariaDB server; we still have this error: 2024-09-11 12:40:47,065 INFO [852] [org.apache.flink.runtime.executiongraph.Execution.transitionState(Execution.java:1446)] - Source: TableSourceScan(table=[[default_catalog, default_database, t_close_domain_category_cdc]],...
**Reproduction** Run test in `BinaryLogClientIntegrationTest` ``` @Test public void testDeserializationOfTIME() throws Exception { assertEquals(writeAndCaptureRow("time", "'-00:00:01'"), new Serializable[]{ generateTime(1969, 12, 31, 23, 59, 59, 0)}); } ``` Test fails with ```...
https://github.com/osheroff/mysql-binlog-connector-java?tab=readme-ov-file#using-ssl I already have the `ca-cert.pem`, `client-cert.pem`, and `client-key.pem`. The `client-cert.pem` is issued by the `ca-cert.pem`. And the `ca-cert.pem` is a self-signed CA certificate. Does anyone know how to create...
As per Mysql code bsae comments/docs MYSQL_TYPE_VAR_STRING can be used for both Strings and Enum types. The connector code has special handling for checking if MYSQL_TYPE_STRING is actually an Enum...
mysql-binlog-connector-java always had the ability to use a customised `EventDeserializer`. However, [after adding TransactionPayloadEvent support](https://github.com/osheroff/mysql-binlog-connector-java/pull/76), this behaviour is broken as `TransactionPayloadEventDataDeserializer` will rely on stock `EventDeserializer` to perform the parsing...
