class KStreamBuilder extends org.apache.kafka.streams.processor.TopologyBuilder {

    public String newName(final String prefix) {
        return internalStreamsBuilder.newProcessorName(prefix);
    }

}