Use identical multi threaded code structure as // replication to enable binlog subscription from the C client library.

Row events could be receive with
single row resultset
single dynamic column
event_type column like insert , update , delete , replace.

• Enable per table subscription and per column filter
• Enable first init that full scan the subscription

Very popular feature of http://redis.io/topics/pubsub

The next step is to use the driver to create a binary mariadb_publisher
to stdout

mariadb_publisher -uXX -pXX -hxxx.xxx.xxx.xxx -s/tmp/xxx.sock --format=json,xml,avro,protobuf, thrift