class TopologyBuilder {

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

    public  TopologyBuilder();

}