Child pages
  • KIP-562: Allow fetching a key from a single partition rather than iterating over all the stores on an instance

Versions Compared


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


Code Block
package org.apache.kafka.streams;

// Represents all the query options that a user can provide to state what kind of stores it is expecting
public class StoreQueryParameters<T> {

    public static <T> StoreQueryParameters<T> fromNameAndType(final String storeName, final QueryableStoreType<T>  queryableStoreType);

    public StoreQueryParameters<T> withPartition(final Integer partition);

    public StoreQueryParameters<T> enableStaleStores();

    public Integer partition();

    public boolean staleStoresEnabled();

    public String storeName();

    public QueryableStoreType<T> queryableStoreType();