我有一个用例，其中我必须使用NiFi定期为特定索引获取新记录（仅以前未获取的记录），然后将其通过管道传输到执行某些ETL的其他存储。
我不确定如何处理仅提取新记录。有人处理过这样的用例吗？
marish 回答：使用NiFi仅消耗新的ElasticSearch文档
您能否更具体地说明仅获取新记录？ 当您说“ 仅未提取记录” 时，这是否意味着特定的时间轴？ 哪些记录被称为新记录？有特定时间要求吗？
我有一个用例，其中我必须使用NiFi定期为特定索引获取新记录（仅以前未获取的记录），然后将其通过管道传输到执行某些ETL的其他存储。
我不确定如何处理仅提取新记录。有人处理过这样的用例吗？
您能否更具体地说明仅获取新记录？ 当您说“ 仅未提取记录” 时，这是否意味着特定的时间轴？ 哪些记录被称为新记录？有特定时间要求吗？