Istnieje projekt, który pobiera Twój binlog, przekształca go i wysyła do Elasticsearch. Możesz to sprawdzić pod adresem:https://github.com/siddontang/go-mysql-elasticsearch
Innym byłby ten:https://github.com/noplay/python-mysql- replikacja .
Pamiętaj jednak, że niezależnie od tego, co wybierzesz, dobrą praktyką jest wstępne utworzenie indeksu i mapowań przed zindeksowaniem dziennika binarnego. Daje to większą kontrolę nad danymi.
AKTUALIZACJA:
Oto kolejny interesujący artykuł na ten temat:Jak zachować synchronizację Elasticsearch z relacyjną bazą danych za pomocą Logstash
