class TopologyBuilder {

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

    public  TopologyBuilder();

}