mysql-binlog-connector-java
mysql-binlog-connector-java copied to clipboard
shyiko
MySQL Binary Log connector
For BIT datatype, the values returned are {0} / {} instead of 1 / 0 respectively To elaborate, When database has value - 1 incase of BIT datatype, it is...
While we already can pass in a `ThreadFactory`when bootstrapping the binlog client, any thread names will be overridden. This makes it more complex to keep track of individual threads in...
I can see there is a GtidSet, the format is defined by mysql, but for MariaDB there is an different format described here https://mariadb.com/kb/en/mariadb/global-transaction-id/
I'm reading the binary logs from a MySQL cluster that is distributed cross DC. My main datacenter (let's call it A) and my secondary datatacenter (let's call it B). In...
Using mysql-binlog-connector-java through Debezium. After shutting down the instance and starting it again, `SecondsBehindMaster` will show a high number. This is exactly the number of seconds passed between shutdown and...
Hello. I maintain a fork of this library (and Debezium[0]) primarily to support a custom binlog event[1] from Twitter's fork of mysql. In order to support different flavors of mysql...
We have use case where thread is continuously listening the bin log file for table row modification and trigger specific event on Update. There is case frequent scenario where multiple...
haven't seen any solution about mutli deployment with Hight Available , is this a single point solution ?
Add a new mode of EventDataDeserializer compatibility, 'DATE_AND_TIME_AS_STRING': Date:'yyyy-mm-dd' Time:'HH:mm:ss' Timestamp/Datetime:'yyyy-mm-dd HH:mm:ss' Year:'yyyy'
import java.io.BufferedInputStream; import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.URL; import java.net.URLDecoder; import java.util.ArrayList; import java.util.Date; import java.util.Properties; import java.util.Set; import com.github.shyiko.mysql.binlog.BinaryLogClient;...
