class ProcessorStateManager {

    public StateStore getStore(String name) {
        return stores.get(name);
    }

    public  ProcessorStateManager(String applicationId, int defaultPartition, Collection<TopicPartition> sources, File baseDir, Consumer<byte[], byte[]> restoreConsumer, boolean isStandby);

}