Det finns ett befintligt projekt som tar din binlog, omvandlar den och skickar den till Elasticsearch. Du kan kolla in det på:https://github.com/siddontang/go-mysql-elasticsearch
En annan skulle vara den här:https://github.com/noplay/python-mysql- replikering .
Observera dock att vad du än väljer är det en god praxis att förskapa ditt index och dina mappningar innan du indexerar din binlog. Det ger dig mer kontroll över din data.
UPPDATERING:
Här är en annan intressant bloggartikel om ämnet:Hur man håller Elasticsearch synkroniserad med en relationsdatabas med Logstash