class TopologyBuilder {

    public synchronized final TopologyBuilder addStateStore(final StateStoreSupplier supplier,
                                                            final String... processorNames) {
        try {
            internalTopologyBuilder.addStateStore(supplier, processorNames);
        } catch (final TopologyException e) {
            throw new org.apache.kafka.streams.errors.TopologyBuilderException(e);
        }
        return this;
    }

    public  TopologyBuilder();

}