diff --git a/pymysqlreplication/packet.py b/pymysqlreplication/packet.py index cb60ba9d..6b66cc53 100644 --- a/pymysqlreplication/packet.py +++ b/pymysqlreplication/packet.py @@ -345,8 +345,6 @@ def unpack_int32(self, n): def read_binary_json(self, size): length = self.read_uint_by_size(size) - payload = self.read(length) - self.unread(payload) t = self.read_uint8() return self.read_binary_json_type(t, length)