Има съществуващ проект, който взема вашия binlog, го трансформира и го изпраща до Elasticsearch. Можете да го проверите на:https://github.com/siddontang/go-mysql-elasticsearch
Друг би бил този:https://github.com/noplay/python-mysql- репликация .
Имайте предвид обаче, че каквото и да изберете, добра практика е предварително да създадете своя индекс и съпоставяния, преди да индексирате своя binlog. Това ви дава повече контрол върху вашите данни.
АКТУАЛИЗИРАНЕ:
Ето още една интересна статия в блога по темата:Как да поддържате Elasticsearch синхронизиран с релационна база данни с помощта на Logstash
