Agile BoardAttach filesAttach ScreenshotVotersStop watchingWatchersLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.10.1.0
    • 0.10.1.0
    • streams
    • 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

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            damianguy Damian Guy
            damianguy Damian Guy
            Votes:
            0 Vote for this issue
            Watchers:
            5 Stop watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment