With a real time application, nobody is interested in old data, and in particular they're not interested in paying to spend time processing it only to throw it away, thereby delaying up to date data.
How do I tell StreamsBuilder.stream() to read only new data from its topic, and not process any backlog? Tim Ward This email is from Origami Energy Limited. The contents of this email and any attachment are confidential to the intended recipient(s). If you are not an intended recipient: (i) do not use, disclose, distribute, copy or publish this email or its contents; (ii) please contact Origami Energy Limited immediately; and then (iii) delete this email. For more information, our privacy policy is available here: https://origamienergy.com/privacy-policy/. Origami Energy Limited (company number 8619644) is a company registered in England with its registered office at Ashcombe Court, Woolsack Way, Godalming, GU7 1LQ.