TopologyBuilder { public synchronized final TopologyBuilder addSink(String name, String topic, String... parentNames) { return addSink(name, topic, (Serializer) null, (Serializer) null, parentNames); } TopologyBuilder(); synchronized final TopologyBuilder addSource(String name, String... topics); synchronized final TopologyBuilder addSource(String name, Deserializer keyDeserializer, Deserializer valDeserializer, String... topics); synchronized final TopologyBuilder addSink(String name, String topic, String... parentNames); synchronized final TopologyBuilder addSink(String name, String topic, StreamPartitioner partitioner, String... parentNames); synchronized final TopologyBuilder addSink(String name, String topic, Serializer keySerializer, Serializer valSerializer, String... parentNames); synchronized final TopologyBuilder addSink(String name, String topic, Serializer<K> keySerializer, Serializer<V> valSerializer, StreamPartitioner<K, V> partitioner, String... parentNames); synchronized final TopologyBuilder addProcessor(String name, ProcessorSupplier supplier, String... parentNames); synchronized final TopologyBuilder addStateStore(StateStoreSupplier supplier, boolean isInternal, String... processorNames); synchronized final TopologyBuilder addStateStore(StateStoreSupplier supplier, String... processorNames); synchronized final TopologyBuilder connectProcessorAndStateStores(String processorName, String... stateStoreNames); synchronized final TopologyBuilder connectProcessors(String... processorNames); synchronized final TopologyBuilder addInternalTopic(String topicName); synchronized Map<Integer, TopicsInfo> topicGroups(String applicationId); synchronized Map<Integer, Set<String>> nodeGroups(); synchronized final TopologyBuilder copartitionSources(Collection<String> sourceNodes); synchronized Collection<Set<String>> copartitionGroups(); synchronized ProcessorTopology build(String applicationId, Integer topicGroupId); synchronized Set<String> sourceTopics(String applicationId);  }
@Test(expected = TopologyBuilderException.class) public void testAddSinkWithWrongParent() { final TopologyBuilder builder = new TopologyBuilder(); builder.addSink("sink", "topic-2", "source"); }
@Test(expected = TopologyBuilderException.class) public void testAddSinkWithSelfParent() { final TopologyBuilder builder = new TopologyBuilder(); builder.addSink("sink", "topic-2", "sink"); }