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

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