Existe um projeto existente que pega seu log binário, o transforma e o envia para o Elasticsearch. Você pode conferir em:https://github.com/siddontang/go-mysql-elasticsearch

Outro seria este:https://github.com/noplay/python-mysql- replicação .

Observe, no entanto, que, seja qual for a sua escolha, é uma boa prática pré-criar seu índice e mapeamentos antes de indexar seu log binário. Isso lhe dá mais controle sobre seus dados.

ATUALIZAÇÃO:

Aqui está outro artigo de blog interessante sobre o assunto:Como manter o Elasticsearch sincronizado com um banco de dados relacional usando o Logstash