Esiste un progetto esistente che prende il tuo binlog, lo trasforma e lo spedisce a Elasticsearch. Puoi verificarlo all'indirizzo:https://github.com/siddontang/go-mysql-elasticsearch
Un altro sarebbe questo:https://github.com/noplay/python-mysql- replica .
Nota, tuttavia, che qualunque sia la tua scelta, è una buona pratica pre-creare il tuo indice e le tue mappature prima di indicizzare il tuo binlog. Questo ti dà un maggiore controllo sui tuoi dati.
AGGIORNAMENTO:
Ecco un altro interessante articolo del blog sull'argomento:Come mantenere Elasticsearch sincronizzato con un database relazionale utilizzando Logstash
