如果还需要通知DELETE并删除Elasticsearch中的相应记录,那么Logstash
jdbc输入确实没有帮助。您必须按照此处的建议使用解决方案来处理binlog
但是,如果仍然要使用Logstashjdbc输入,则可以做的就是在PostgreSQL中简单地软删除记录,即创建一个新的BOOLEAN列以将记录标记为
deleted。然后,Elasticsearch中将存在相同的标志,您可以
term通过对该
deleted字段进行简单查询就将它们从搜索中排除。
每当需要执行一些清理时,都可以删除
deletedPostgreSQL和Elasticsearch中标记的所有记录。



