Pokud potřebujete být upozorněni i na DELETE a smazat příslušný záznam v Elasticsearch, je pravda, že vstup Logstash jdbc nepomůže. Museli byste použít řešení, které funguje kolem binlogu jako doporučeno zde
Pokud však přesto chcete použít vstup Logstash jdbc, můžete jednoduše odstranit záznamy v PostgreSQL, tj. vytvořit nový sloupec BOOLEAN, abyste své záznamy označili jako deleted
. Stejný příznak by pak existoval v Elasticsearch a můžete je vyloučit ze svých vyhledávání pomocí jednoduchého term
dotaz na deleted
pole.
Kdykoli potřebujete provést nějaké vyčištění, můžete smazat všechny záznamy označené jako deleted
v PostgreSQL i Elasticsearch.