@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");
}