binlogを取得して変換し、Elasticsearchに送信する既存のプロジェクトがあります。次のURLで確認できます： https://github.com/siddontang/go-mysql-elasticsearch
もう1つはこれです： https://github.com/noplay/python-mysql-レプリケーション 。
ただし、どちらを選択する場合でも、binlogにインデックスを付ける前に、インデックスとマッピングを事前に作成しておくことをお勧めします。これにより、データをより細かく制御できます。
更新：
このテーマに関する別の興味深いブログ記事は次のとおりです。