Versions Compared

Old Version 2

changes.mady.by.user Navinder Pal Singh Brar

Saved on

compared with

New Version 3

changes.mady.by.user Navinder Pal Singh Brar

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

  • Add a new public class StoreQueryParams.java to set options for what kind of stores a user wants.
  • Create a taskId from the combination of store name and partition provided by the user.
  • In StreamThreadStateStoreProvider.java return only the stores for the task requested by the user along with the check and also check the condition to return only running store stores or standby and /recovering stores as well.

...

Compatibility, Deprecation, and Migration Plan:

  • No deprecation required as this KIP changes the definition of As a part of KIP-535  KIP the functions QueryableStoreProvider#getStore() and StreamThreadStateStoreProvider#stores() and users have to adapt to the new functionshave already been changed so we will overwrite those functions once more before merging shipping both the features together in 2.5.0.


Rejected Alternatives:

  • Overload the QueryableStoreProvider#getStore() and StreamThreadStateStoreProvider#stores() with new parameters to pass a list of partitions along with the currently passed flag includeStaleStores.