Jeśli musisz być również powiadamiany o DELETE i usunąć odpowiedni rekord w Elasticsearch, to prawda, że dane wejściowe jdbc Logstash nie pomogą. Musiałbyś użyć rozwiązania działającego na binlogu jako sugerowane tutaj
Jeśli jednak nadal chcesz używać danych wejściowych jdbc Logstash, możesz po prostu soft-deletować rekordy w PostgreSQL, tj. utworzyć nową kolumnę BOOLEAN, aby oznaczyć swoje rekordy jako deleted . Ta sama flaga istniałaby wtedy w Elasticsearch i można ją wykluczyć z wyszukiwania za pomocą prostego term zapytanie dotyczące deleted pole.
Za każdym razem, gdy potrzebujesz wykonać pewne czyszczenie, możesz usunąć wszystkie rekordy oznaczone jako deleted zarówno w PostgreSQL, jak i Elasticsearch.
