class TopologyBuilder {

    public synchronized ProcessorTopology build(final Integer topicGroupId) {
        return internalTopologyBuilder.build(topicGroupId);
    }

    public  TopologyBuilder();

}