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

Interactive Query v2

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Closed
    • Major
    • Resolution: Fixed
    • None
    • 3.2.0
    • streams
    • None

    Description

      Kafka Streams supports an interesting and innovative API for "peeking" into the internal state of running stateful stream processors from outside of the application, called Interactive Query (IQ). This functionality has proven invaluable to users over the years for everything from debugging running applications to serving low latency queries straight from the Streams runtime.

      However, the actual interfaces for IQ were designed in the very early days of Kafka Streams, before the project had gained significant adoption, and in the absence of much precedent for this kind of API in peer projects. With the benefit of hindsight, we can observe several problems with the original design that we hope to address in a revised framework that will serve Streams users well for many years to come.

       

      This ticket tracks the implementation of KIP-796: https://cwiki.apache.org/confluence/x/34xnCw

      Attachments

        Issue Links

          relates to

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-13523 Implement IQv2 support in global stores

          • Major - Major loss of function.
          • Open

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-13526 IQv2: Consider more generic logic for mapping between binary and typed queries

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Open

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-13541 Make IQv2 query/store interface type safe

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Open

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-13548 IQv2: revisit WindowKeyQuery and WindowRangeQuery

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Open

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-13622 Revisit the complexity of position tracking in state stores

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Open
          links to

          Web Link GitHub Pull Request #11598

          Activity

            People

              vvcephei John Roesler
              vvcephei John Roesler
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: