У меня есть таблица транзакций в базе данных MySQL. При каждом обновлении таблицы транзакций (т.е. вставке новой записи) я хочу немедленно проиндексировать ее в индекс elasticsearch. Я наткнулся на эту статью ВСТАВИТЬ В ЖУРНАЛ ВЫБРАТЬ ДАННЫЕ ИЗ БАЗЫ ДАННЫХ, но она синхронизирует таблицу базы данных только при перезапуске logstash, а не продолжает ее просмотр. Может кто-нибудь предложить мне способ сделать это.
Это решило мою проблему, спасибо
этот ответ может помочь: stackoverflow.com/questions/38631322/…