class TopologyBuilder {

    public synchronized final TopologyBuilder connectProcessorAndStateStores(final String processorName,
                                                                             final String... stateStoreNames) {
        if (stateStoreNames != null && stateStoreNames.length > 0) {
            try {
                internalTopologyBuilder.connectProcessorAndStateStores(processorName, stateStoreNames);
            } catch (final TopologyException e) {
                throw new org.apache.kafka.streams.errors.TopologyBuilderException(e);
            }
        }
        return this;
    }

    public  TopologyBuilder();

}