Er is een bestaand project dat uw binlog neemt, het transformeert en naar Elasticsearch verzendt. U kunt het bekijken op:https://github.com/siddontang/go-mysql-elasticsearch
Een andere zou deze zijn:https://github.com/noplay/python-mysql- replicatie .
Merk echter op dat wat u ook kiest, het een goede gewoonte is om uw index en toewijzingen vooraf te maken voordat u uw binlog indexeert. Dat geeft u meer controle over uw gegevens.
UPDATE:
Hier is nog een interessant blogartikel over dit onderwerp:Hoe Elasticsearch gesynchroniseerd te houden met een relationele database met Logstash