Major Description
Currently, in Kafka Streams, KTable API does not allow users to query for entries with a specific timestamp. The goal of this ticket is to allow a couple of things:
- Retrieve entries in KTable that were inserted in the last K milliseconds where K could be determined by the user
- Find key-value pairs which were put into the KTable in a specified time interval.
KTable already has methods like filter and filterNot, but the information available to the user in these methods does not include the publish timestamp.
The best way to do this is probably to add new methods which creates a new KTable based solely on timestamp.