hello everyone, right now I'm using flink to sync from mysql to elasticsearch and so far so good. If we insert, update, or delete it will sync from mysql to elastic without any problem.
The problem I have right now is the application is not actually doing hard delete to the records in mysql, but doing soft delete (updating a deletedAt column). Because it's not actually doing a deletion, flink is not deleting the data in elastic. How do I make it so it will delete the data in elastic? Thanks
