Ada proyek yang mengambil binlog Anda, mengubahnya dan mengirimkannya ke Elasticsearch, Anda dapat memeriksanya di:https://github.com/siddontang/go-mysql-elasticsearch
Yang lain adalah yang ini:https://github.com/noplay/python-mysql- replikasi .
Namun, perhatikan bahwa apa pun yang Anda pilih, merupakan praktik yang baik untuk membuat indeks dan pemetaan terlebih dahulu sebelum mengindeks binlog Anda. Itu memberi Anda lebih banyak kontrol atas data Anda.
PERBARUI:
Berikut ini adalah artikel blog menarik lainnya tentang topik ini:Cara menjaga sinkronisasi Elasticsearch dengan database relasional menggunakan Logstash