Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-8388

Add methods to query for entries in KTable using timestamp

    XMLWordPrintableJSON

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: streams
    • Labels:

      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. 

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              Yohan123 Richard Yu
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated: