Merge pull request #7 from fivetran/unknown-events

Create unknown event type for invalid and proprietary event types. Re…

Author: fivetran-shivavanamala

src/main/java/com/github/shyiko/mysql/binlog/event/EventType.java

@@ -192,21 +192,25 @@ public enum EventType {
     /**
      * Prepared XA transaction terminal event similar to XID except that it is specific to XA transaction.
      */
-    XA_PREPARE(38),
-    AURORA_PADDING(100);
+    XA_PREPARE(38);
 
     private final int eventId;
 
     EventType(int eventId) {
         this.eventId = eventId;
     }
 
+    /**
+     * Parses the event type based on the ordinal.
+     * 
+     * <p>If an invalid or proprietary ordinal is passed, EventType.UNKNOWN is returned.
+     */
     public static EventType forId(int eventId) {
         for (EventType type : EventType.values()) {
             if (type.eventId == eventId) return type;
         }
 
-        return null;
+        return EventType.UNKNOWN;
     }
 
     public static boolean isRowMutation(EventType eventType) {

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/EventHeaderV4Deserializer.java

@@ -30,20 +30,11 @@ public class EventHeaderV4Deserializer implements EventHeaderDeserializer<EventH
     public EventHeaderV4 deserialize(ByteArrayInputStream inputStream) throws IOException {
         EventHeaderV4 header = new EventHeaderV4();
         header.setTimestamp(inputStream.readLong(4) * 1000L);
-        header.setEventType(getEventType(inputStream.readInteger(1)));
+        header.setEventType(EventType.forId(inputStream.readInteger(1)));
         header.setServerId(inputStream.readLong(4));
         header.setEventLength(inputStream.readLong(4));
         header.setNextPosition(inputStream.readLong(4));
         header.setFlags(inputStream.readInteger(2));
         return header;
     }
-
-    private static EventType getEventType(int ordinal) throws IOException {
-        EventType eventType = EventType.forId(ordinal);
-
-        if (eventType == null) {
-            throw new IOException("Unknown event type " + ordinal);
-        }
-        return eventType;
-    }
 }