[
https://issues.apache.org/jira/browse/KAFKA-8388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843159#comment-16843159
]
Matthias J. Sax commented on KAFKA-8388:
----------------------------------------
Thanks for creating this ticket.
{quote} # Modify the current {{filter}} and {{filterNot}} methods so that the
timestamp information is also available to the user for reference.{quote}
I am not sure if this would work. When a new record is inserted in the input
KTable, it would pass the filter and be added to the result KTable. However,
after time progressed, this record would need to be removed from the result
again. However, filter() would only be called for updates to the input KTable.
Thus, I am not sure if this would work.
> Add methods to query for entries in KTable using timestamp
> ----------------------------------------------------------
>
> Key: KAFKA-8388
> URL: https://issues.apache.org/jira/browse/KAFKA-8388
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: Richard Yu
> Priority: Major
> Labels: needs-kip
>
> 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.
> A couple of things we could do to attack this issue:
> # Modify the current {{filter}} and {{filterNot}} methods so that the
> timestamp information is also available to the user for reference.
> # Add new methods which creates a new KTable based solely on timestamp.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
