Details

    • Type: Sub-task
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.10.1.0
    • Fix Version/s: 0.10.1.0
    • Component/s: streams
    • Labels:
      None

      Description

      Implement read-only interface and QueryableStoreType for key-value state store

      Implement read-only interface and QueryableStoreType for windowed state store

      Ensure store operations are thread-safe. I.e., a single state store could have concurrent access, e.g. one stream worker thread updating the store, and one user thread querying the store.

      Ensure failure and rebalancing is handled correctly. I.e., because the "read-only" state store interface could wrap multiple state stores, since one instance could contain multiple tasks and hence multiple state stores with the same names. Rebalance could happen migrating state stores in / out while the user is interacting with the interface.

      Add the following method to KafkaStreams

       
      public <T> T getStore(final String storeName,final QueryableStoreType<T> queryableStoreType)
      

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                damianguy Damian Guy
                Reporter:
                damianguy Damian Guy
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: