Stream processing engines are meant to work with ephemeral data, fast data. Couldn't you just use a database to query 'all time'?