diff --git a/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java b/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java index a3384df5..2d8bcdd8 100644 --- a/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java +++ b/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java @@ -34,7 +34,7 @@ public EventHeaderV4 deserialize(ByteArrayInputStream inputStream) throws IOExce header.setTimestamp(inputStream.readLong(4) * 1000L); header.setEventType(getEventType(inputStream.readInteger(1))); header.setServerId(inputStream.readLong(4)); - header.setEventLength(inputStream.readInteger(4)); + header.setEventLength(inputStream.readLong(4)); header.setNextPosition(inputStream.readLong(4)); header.setFlags(inputStream.readInteger(2)); return header;