[feature request] expose methods for handling raw event data.

[thomasdziedzic]

I would like to publish the raw event data, and then parse the event data on the subscribers to let them handle the events themselves.

[shyiko]

This should do the trick:

BinaryLogClient client = ...
EventDeserializer eventDeserializer = new EventDeserializer(
    new EventHeaderV4Deserializer(),
    new ByteArrayEventDataDeserializer(),
    new HashMap<EventType, EventDataDeserializer>() {{
        // TABLE_MAP and ROTATE events are used internally by EventDeserializer/BinaryLogClient
        put(EventType.TABLE_MAP, new TableMapEventDataDeserializer());
        put(EventType.ROTATE, new RotateEventDataDeserializer());
    }},
    new HashMap<Long, TableMapEventData>()
);
client.setEventDeserializer(eventDeserializer);

Alternatively, you can explicitly specify type of events that should skip payload deserialization. Like so:

    BinaryLogClient client = ...
    EventDeserializer eventDeserializer = new EventDeserializer();
    eventDeserializer.setEventDataDeserializer(EventType.EXT_WRITE_ROWS, 
new ByteArrayEventDataDeserializer());
    eventDeserializer.setEventDataDeserializer(EventType.EXT_UPDATE_ROWS, 
new ByteArrayEventDataDeserializer());
    eventDeserializer.setEventDataDeserializer(EventType.EXT_DELETE_ROWS, 
new ByteArrayEventDataDeserializer());
    client.setEventDeserializer(eventDeserializer);

Let me know if that's enough.

[thomasdziedzic]

This looks great, is there any way this can be documented somewhere?

I can see a lot of people using this if they want to setup a pub-sub with the binlog data.

[shyiko]

Added a few examples in 024ade9.