[MySQL] Fix for DBZ-7037 and apache#2217 to not clear tableMapEventBy…

…TableId for fake Rotates Event (apache#3065)
wuzhenhua01 · Aug 4, 2024 · fcf6f75 · fcf6f75
1 parent f6e8ad0
commit fcf6f75
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java b/...-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java
@@ -268,7 +268,8 @@ public Event nextEvent(ByteArrayInputStream inputStream) throws IOException {
 
                             // DBZ-5126 Clean cache on rotate event to prevent it from growing
                             // indefinitely.
-                            if (event.getHeader().getEventType() == EventType.ROTATE) {
+                            if (event.getHeader().getEventType() == EventType.ROTATE
+                                    && event.getHeader().getTimestamp() != 0) {
                                 tableMapEventByTableId.clear();
                             }
                             return event;