Add error logging for crc32 validation failures

Co-authored-by: jaehyeonpy [email protected]
Co-authored-by: davinc71998 [email protected]

Author: why-arong

pymysqlreplication/event.py

@@ -3,6 +3,7 @@
 import datetime
 import decimal
 import zlib
+import logging
 
 from pymysqlreplication.constants.STATUS_VAR_KEY import *
 from pymysqlreplication.exceptions import StatusVariableMismatch
@@ -57,7 +58,14 @@ def _verify_event(self):
         data = self.packet.read(19 + self.event_size)
         footer = self.packet.read(4)
         byte_data = zlib.crc32(data).to_bytes(4, byteorder="little")
-        self._is_event_valid = True if byte_data == footer else False
+        if byte_data == footer:
+            self._is_event_valid = True
+        else:
+            self._is_event_valid = False
+            logging.error(
+                f"An CRC32 has failed for the event type {self.event_type}, "
+                "indicating a potential integrity issue with the data."
+            )
         self.packet.read_bytes -= 19 + self.event_size + 4
         self.packet.rewind(20)