Nếu bạn cũng cần được thông báo về DELETE và xóa bản ghi tương ứng trong Elasticsearch, thì đúng là đầu vào Logstash jdbc sẽ không giúp được gì. Bạn phải sử dụng một giải pháp xử lý binlog là được đề xuất ở đây
Tuy nhiên, nếu bạn vẫn muốn sử dụng đầu vào Logstash jdbc, những gì bạn có thể làm chỉ là xóa mềm các bản ghi trong PostgreSQL, tức là tạo một cột BOOLEAN mới để đánh dấu các bản ghi của bạn là deleted
. Sau đó, cùng một cờ sẽ tồn tại trong Elasticsearch và bạn có thể loại trừ chúng khỏi các tìm kiếm của mình bằng một term
đơn giản truy vấn trên deleted
trường.
Bất cứ khi nào bạn cần thực hiện một số dọn dẹp, bạn có thể xóa tất cả các bản ghi được gắn cờ deleted
trong cả PostgreSQL và Elasticsearch.