diff --git a/pymysqlreplication/row_event.py b/pymysqlreplication/row_event.py
index fcd138d3..a1a46ea5 100644
--- a/pymysqlreplication/row_event.py
+++ b/pymysqlreplication/row_event.py
@@ -62,7 +62,7 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs)
 
                     # ndb information
                     if self.extra_data_type == 0:
-                        self.nbd_info_length, self.nbd_info_format = struct.unpack('<BB', self.packet.read(1))
+                        self.nbd_info_length, self.nbd_info_format = struct.unpack('<BB', self.packet.read(2))
                         self.nbd_info = self.packet.read(self.nbd_info_length - 2)
                     # partition information
                     elif self.extra_data_type == 1: