Il existe un projet existant qui prend votre binlog, le transforme et l'envoie à Elasticsearch, vous pouvez le vérifier sur :https://github.com/siddontang/go-mysql-elasticsearch
Un autre serait celui-ci :https://github.com/noplay/python-mysql- réplication .
Notez cependant que, quel que soit votre choix, il est recommandé de pré-créer votre index et vos mappages avant d'indexer votre binlog. Cela vous donne plus de contrôle sur vos données.
MISE À JOUR :
Voici un autre article de blog intéressant sur le sujet :Comment synchroniser Elasticsearch avec une base de données relationnelle à l'aide de Logstash
