-
Bug
-
Resolution: Done
-
Critical
-
0.9.0.Beta1
-
None
Let's suppose there are two MySQL databases in master/master setup with HA proxy in front of it
1) Debezium is connected to database 1
2) Events are processed form database
3) Database 1 is shutdown
4) New records are added to database 2
4) Debezium is connected to database 2
5) Database 2 reports a GTID set of GTIDs coming from database 1 and its own GTIDs
6) Debezium fiters out Database 2 GTIDs because io.debezium.connector.mysql.MySqlTaskContext.filterGtidSet(GtidSet, GtidSet) does not remove database 2 UUIDs from filtered set as it does not have any recorded to overwrite
7) All records that were written before Debezium restart are lost