Logstash sync from Oracle to MongoDB and Elasticsearch insert duplicate records when doing partial update

We are facing issue of getting duplicate records with Logstash JDBC plugin when syncing Oracle to MongoDB and Elasticsearch after every 1 minute. How we can do partial update ,so that delta/modified records should only be inserted on every 1 minute incremental sync/update.

Your help will be appreciated.

Have you fixed the duplicate issue while sync up the oracle to Elasticsearch