how about a processor that checks in your pipeline for the date of the timestamp that the document provided? If that is older than X, you could use the drop processor.
Apache, Apache Lucene, Apache Hadoop, Hadoop, HDFS and the yellow elephant
logo are trademarks of the
Apache Software Foundation
in the United States and/or other countries.