class KStreamImpl extends AbstractStream<K> implements KStream<K, V> {

    @Override
    public void to(String topic) {
        to(null, null, null, topic);
    }

    public  KStreamImpl(KStreamBuilder topology, String name, Set<String> sourceNodes);

}