KStreamBuilder extends TopologyBuilder { public <K, V> KStream<K, V> stream(String... topics) { return stream(null, null, topics); } KStreamBuilder(); KStream<K, V> stream(String... topics); KStream<K, V> stream(Serde<K> keySerde, Serde<V> valSerde, String... topics); KTable<K, V> table(String topic); KTable<K, V> table(Serde<K> keySerde, Serde<V> valSerde, String topic); KStream<K, V> merge(KStream<K, V>... streams); String newName(String prefix);  }
@Test(expected = TopologyBuilderException.class) public void testFrom() { final KStreamBuilder builder = new KStreamBuilder(); builder.stream("topic-1", "topic-2"); builder.addSource(KStreamImpl.SOURCE_NAME + "0000000000", "topic-3"); }