In the event that the table is fully qualified in a DDL statement ensure

that the provided schema matches the replicatedSchema. This catches
situations in which the context of the query matches the
replicatedSchema but the query itself modifies a table in a different
schema.

Author: steveauri

mysql-replicator-augmenter/src/main/java/com/booking/replication/augmenter/AugmenterContext.java

@@ -486,7 +486,14 @@ private void processQueryEvent(RawEventHeaderV4 eventHeader, RawEventData eventD
 
             // If the tableName contains a period it has both a schema and table name
             if ( tableName.indexOf(".") != -1 ) {
-                tableName = tableName.split("\\.")[1];
+                String[] matches = tableName.split("\\.");
+                String schema = matches[0].replaceAll("`","");
+                if ( !schema.equals(replicatedSchema) ) {
+                    LOG.info("Skipping DDL TABLE event due to affected table schema (" + schema + ") not matching replicatedSchema (" + replicatedSchema + "), while the getDatabase() ("+ queryRawEventData.getDatabase() + ") schema *DOES* match replicatedSchema");
+                    shouldProcess = false;
+                } else {
+                    tableName = matches[1];
+                }
             }
 
             if (tableName.startsWith("`") && tableName.endsWith("`")) {