Existuje již existující projekt, který vezme váš binlog, transformuje jej a odešle do Elasticsearch. Můžete se na něj podívat na:https://github.com/siddontang/go-mysql-elasticsearch
Další by byl tento:https://github.com/noplay/python-mysql- replikace .
Pamatujte však, že bez ohledu na to, co si vyberete, je dobré si před indexováním svého binlogu předem vytvořit index a mapování. To vám dává větší kontrolu nad svými daty.
AKTUALIZACE:
Zde je další zajímavý článek na blogu na toto téma:Jak udržovat Elasticsearch synchronizované s relační databází pomocí Logstash