From 566efd6a3f490d59457db99b668ca6ceb1c05c3a Mon Sep 17 00:00:00 2001
From: Jiri Pechanec <jpechane@redhat.com>
Date: Fri, 14 Feb 2020 13:59:41 +0100
Subject: [PATCH] DBZ-1775 Filter out rds_monitor DML events

---
 .../io/debezium/relational/history/DatabaseHistory.java   | 1 +
 .../test/java/io/debezium/config/ConfigurationTest.java   | 8 ++++++++
 2 files changed, 9 insertions(+)

diff --git a/debezium-core/src/main/java/io/debezium/relational/history/DatabaseHistory.java b/debezium-core/src/main/java/io/debezium/relational/history/DatabaseHistory.java
index 20697c4af..c54d8ac52 100644
--- a/debezium-core/src/main/java/io/debezium/relational/history/DatabaseHistory.java
+++ b/debezium-core/src/main/java/io/debezium/relational/history/DatabaseHistory.java
@@ -64,6 +64,7 @@ public interface DatabaseHistory {
                             "INSERT INTO mysql.rds_heartbeat2\\(.*\\) values \\(.*\\) ON DUPLICATE KEY UPDATE value = .*," +
                             "DELETE FROM mysql.rds_sysinfo.*," +
                             "INSERT INTO mysql.rds_sysinfo\\(.*\\) values \\(.*\\)," +
+                            "DELETE FROM mysql.rds_monitor.*," +
                             "FLUSH RELAY LOGS.*," +
                             "flush relay logs.*," +
                             "SAVEPOINT .*")
diff --git a/debezium-core/src/test/java/io/debezium/config/ConfigurationTest.java b/debezium-core/src/test/java/io/debezium/config/ConfigurationTest.java
index 03f499d15..175dea03a 100644
--- a/debezium-core/src/test/java/io/debezium/config/ConfigurationTest.java
+++ b/debezium-core/src/test/java/io/debezium/config/ConfigurationTest.java
@@ -154,6 +154,14 @@ public void defaultDdlFilterShouldFilterOutRdsSysinfoStatements() {
         assertThat(ddlFilter.test("INSERT INTO mysql.rds_sysinfo(name, value) values ('innodb_txn_key','Thu Sep 19 19:38:23 UTC 2019')")).isTrue();
     }
 
+    @Test
+    @FixFor("DBZ-1775")
+    public void defaultDdlFilterShouldFilterOutRdsMonitorStatements() {
+        String defaultDdlFilter = Configuration.create().build().getString(DatabaseHistory.DDL_FILTER);
+        Predicate<String> ddlFilter = Predicates.includes(defaultDdlFilter);
+        assertThat(ddlFilter.test("DELETE FROM mysql.rds_monitor")).isTrue();
+    }
+
     @Test
     @FixFor("DBZ-1015")
     public void testMsgKeyColumnsField() {