Interface StateStoreProvider

    • Method Detail

      • stores

        <T> java.util.List<T> stores​(java.lang.String storeName,
                                     QueryableStoreType<T> queryableStoreType)
        Find instances of StateStore that are accepted by QueryableStoreType.accepts(org.apache.kafka.streams.processor.StateStore) and have the provided storeName.
        Type Parameters:
        T - The type of the Store
        Parameters:
        storeName - name of the store
        queryableStoreType - filter stores based on this queryableStoreType
        Returns:
        List of the instances of the store in this topology. Empty List if not found