发布于 2016-09-11 08:04:52
最好的方法是使用GTID (java支持哪些mysql-binlog-连接器?),但是就像Michael说的那样,它需要5.6+。如果您完全没有办法升级,并且您了解所涉及的风险,那么获得您自己的-开始-日期时间非常简单:
BinaryLogClient binaryLogClient = new BinaryLogClient(...);
binaryLogClient.setBinlogFilename(""); // instructs server to stream events
// starting from the oldest known binlog
final long start = ...
binaryLogClient.registerEventListener(new BinaryLogClient.EventListener() {
@Override
public void onEvent(Event event) {
if (event.getHeader().getTimestamp() < start) {
return;
}
// process the event here
}
});
binaryLogClient.connect();注意: binlog事件的时间戳具有秒精度。
https://stackoverflow.com/questions/39386623
复制相似问题