public synchronized Topology connectProcessorAndStateStores(final String processorName,
                                                                final String... stateStoreNames) {
        internalTopologyBuilder.connectProcessorAndStateStores(processorName, stateStoreNames);
        return this;
    }
Connects the processor and the state stores.

@param processorName the name of the processor
@param stateStoreNames the names of state stores that the processor uses
@return itself
@throws TopologyException if the processor or a state store is unknown
streams/src/main/java/org/apache/kafka/streams/Topology.java