class KStreamBuilder extends TopologyBuilder {

    public <K, V> KStream<K, V> merge(KStream<K, V>... streams) {
        return KStreamImpl.merge(this, streams);
    }

    public  KStreamBuilder();

}