У меня миллионы записей в MongoDB, и я хочу использовать NiFi для перемещения данных.Вот сценарий, который я хочу запустить:
1) Я настрою NiFi
2) NiFi автоматически извлечет записи с партиями по 100 записей.
3) Как только это произойдетсделано, он будет извлекаться при добавлении новой записи.
Я попытался применить этот сценарий с небольшой коллекцией MongoDB (извлечь из mongo и сохранить в виде файла), и я увидел, что NiFi повторяет этот процесс навсегда и дублирует записи.
Вот поток, который я создал на NiFi: 
Есть какие-нибудь предложения по решению этой проблемы?