Hay un proyecto existente que toma su binlog, lo transforma y lo envía a Elasticsearch. Puede consultarlo en:https://github.com/siddontang/go-mysql-elasticsearch
Otro sería este:https://github.com/noplay/python-mysql- replicación .
Tenga en cuenta, sin embargo, que cualquiera que elija, es una buena práctica crear previamente su índice y asignaciones antes de indexar su binlog. Eso le da más control sobre sus datos.
ACTUALIZACIÓN:
Aquí hay otro artículo de blog interesante sobre el tema:Cómo mantener Elasticsearch sincronizado con una base de datos relacional usando Logstash
