@Test(expected = TopologyBuilderException.class)
public void testAddSinkWithWrongParent() {

    final TopologyBuilder builder = new TopologyBuilder();
    builder.addSink("sink", "topic-2", "source");
}