diff --git a/debezium-core/src/main/java/io/debezium/relational/Tables.java b/debezium-core/src/main/java/io/debezium/relational/Tables.java
index 00f9ae0c0..3ded2e0b0 100644
--- a/debezium-core/src/main/java/io/debezium/relational/Tables.java
+++ b/debezium-core/src/main/java/io/debezium/relational/Tables.java
@@ -86,7 +86,7 @@ public int size() {
 
     public Set<TableId> drainChanges() {
         return lock.write(() -> {
-            if (changes.isEmpty()) return Collections.emptySet();
+            if (changes.isEmpty()) return Collections.<TableId>emptySet();
             Set<TableId> result = new HashSet<>(changes);
             changes.clear();
             return result;