@Test(expected = TopologyBuilderException.class) public void testNamedTopicMatchesAlreadyProvidedPattern() { final TopologyBuilder builder = new TopologyBuilder(); builder.addSource("source-1", Pattern.compile("f.*")); builder.addSource("source-2", "foo"); }
public synchronized final TopologyBuilder addSource(final String name, final String... topics) { return addSource(null, name, null, null, null, topics); }
TopologyBuilder { public synchronized final TopologyBuilder addSource(final String name, final String... topics) { return addSource(null, name, null, null, null, topics); } }
TopologyBuilder { public synchronized final TopologyBuilder addSource(final String name, final String... topics) { return addSource(null, name, null, null, null, topics); } TopologyBuilder(); }
TopologyBuilder { public synchronized final TopologyBuilder addSource(final String name, final String... topics) { return addSource(null, name, null, null, null, topics); } TopologyBuilder(); synchronized final TopologyBuilder setApplicationId(final String applicationId); synchronized final TopologyBuilder addSource(final String name, final String... topics); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset, final String name, final String... topics); synchronized final TopologyBuilder addSource(final TimestampExtractor timestampExtractor, final String name, final String... topics); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset, final TimestampExtractor timestampExtractor, final String name, final String... topics); synchronized final TopologyBuilder addSource(final String name, final Pattern topicPattern); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset, final String name, final Pattern topicPattern); synchronized final TopologyBuilder addSource(final TimestampExtractor timestampExtractor, final String name, final   Pattern topicPattern); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset, final TimestampExtractor timestampExtractor, final String name, final Pattern topicPattern); synchronized final TopologyBuilder addSource(final String name, final Deserializer keyDeserializer, final Deserializer valDeserializer, final String... topics); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset,
                                                        final String name,
                                                        final TimestampExtractor timestampExtractor,
                                                        final Deserializer keyDeserializer,
                                                        final Deserializer valDeserializer,
                                                        final String... topics); synchronized TopologyBuilder addGlobalStore(final StateStoreSupplier<KeyValueStore> storeSupplier,
                                                       final String sourceName,
                                                       final Deserializer keyDeserializer,
                                                       final Deserializer valueDeserializer,
                                                       final String topic,
                                                       final String processorName,
                                                       final ProcessorSupplier stateUpdateSupplier); synchronized TopologyBuilder addGlobalStore(final StateStoreSupplier<KeyValueStore> storeSupplier,
                                                       final String sourceName,
                                                       final TimestampExtractor timestampExtractor,
                                                       final Deserializer keyDeserializer,
                                                       final Deserializer valueDeserializer,
                                                       final String topic,
                                                       final String processorName,
                                                       final ProcessorSupplier stateUpdateSupplier); synchronized final TopologyBuilder addSource(final String name, final Deserializer keyDeserializer, final Deserializer valDeserializer, final Pattern topicPattern); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset,
                                                        final String name,
                                                        final TimestampExtractor timestampExtractor,
                                                        final Deserializer keyDeserializer,
                                                        final Deserializer valDeserializer,
                                                        final Pattern topicPattern); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset,
                                                        final String name,
                                                        final Deserializer keyDeserializer,
                                                        final Deserializer valDeserializer,
                                                        final Pattern topicPattern); synchronized final TopologyBuilder addSink(final String name, final String topic, final String... parentNames); synchronized final TopologyBuilder addSink(final String name, final String topic, final StreamPartitioner partitioner, final String... parentNames); synchronized final TopologyBuilder addSink(final String name, final String topic, final Serializer keySerializer, final Serializer valSerializer, final String... parentNames); synchronized final TopologyBuilder addSink(final String name, final String topic, final Serializer<K> keySerializer, final Serializer<V> valSerializer, final StreamPartitioner<? super K, ? super V> partitioner, final String... parentNames); synchronized final TopologyBuilder addProcessor(final String name, final ProcessorSupplier supplier, final String... parentNames); synchronized final TopologyBuilder addStateStore(final StateStoreSupplier supplier, final String... processorNames); synchronized final TopologyBuilder connectProcessorAndStateStores(final String processorName, final String... stateStoreNames); synchronized final TopologyBuilder connectProcessors(final String... processorNames); synchronized final TopologyBuilder addInternalTopic(final String topicName); synchronized final TopologyBuilder copartitionSources(final Collection<String> sourceNodes); synchronized Map<Integer, Set<String>> nodeGroups(); synchronized ProcessorTopology build(final Integer topicGroupId); synchronized ProcessorTopology buildGlobalStateTopology(); Map<String, StateStore> globalStateStores(); synchronized Map<Integer, TopicsInfo> topicGroups(); synchronized Pattern earliestResetTopicsPattern(); synchronized Pattern latestResetTopicsPattern(); Map<String, List<String>> stateStoreNameToSourceTopics(); synchronized Collection<Set<String>> copartitionGroups(); SubscriptionUpdates subscriptionUpdates(); synchronized Pattern sourceTopicPattern(); synchronized void updateSubscriptions(final SubscriptionUpdates subscriptionUpdates, final String threadId); }
TopologyBuilder { public synchronized final TopologyBuilder addSource(final String name, final String... topics) { return addSource(null, name, null, null, null, topics); } TopologyBuilder(); synchronized final TopologyBuilder setApplicationId(final String applicationId); synchronized final TopologyBuilder addSource(final String name, final String... topics); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset, final String name, final String... topics); synchronized final TopologyBuilder addSource(final TimestampExtractor timestampExtractor, final String name, final String... topics); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset, final TimestampExtractor timestampExtractor, final String name, final String... topics); synchronized final TopologyBuilder addSource(final String name, final Pattern topicPattern); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset, final String name, final Pattern topicPattern); synchronized final TopologyBuilder addSource(final TimestampExtractor timestampExtractor, final String name, final   Pattern topicPattern); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset, final TimestampExtractor timestampExtractor, final String name, final Pattern topicPattern); synchronized final TopologyBuilder addSource(final String name, final Deserializer keyDeserializer, final Deserializer valDeserializer, final String... topics); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset,
                                                        final String name,
                                                        final TimestampExtractor timestampExtractor,
                                                        final Deserializer keyDeserializer,
                                                        final Deserializer valDeserializer,
                                                        final String... topics); synchronized TopologyBuilder addGlobalStore(final StateStoreSupplier<KeyValueStore> storeSupplier,
                                                       final String sourceName,
                                                       final Deserializer keyDeserializer,
                                                       final Deserializer valueDeserializer,
                                                       final String topic,
                                                       final String processorName,
                                                       final ProcessorSupplier stateUpdateSupplier); synchronized TopologyBuilder addGlobalStore(final StateStoreSupplier<KeyValueStore> storeSupplier,
                                                       final String sourceName,
                                                       final TimestampExtractor timestampExtractor,
                                                       final Deserializer keyDeserializer,
                                                       final Deserializer valueDeserializer,
                                                       final String topic,
                                                       final String processorName,
                                                       final ProcessorSupplier stateUpdateSupplier); synchronized final TopologyBuilder addSource(final String name, final Deserializer keyDeserializer, final Deserializer valDeserializer, final Pattern topicPattern); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset,
                                                        final String name,
                                                        final TimestampExtractor timestampExtractor,
                                                        final Deserializer keyDeserializer,
                                                        final Deserializer valDeserializer,
                                                        final Pattern topicPattern); synchronized final TopologyBuilder addSource(final AutoOffsetReset offsetReset,
                                                        final String name,
                                                        final Deserializer keyDeserializer,
                                                        final Deserializer valDeserializer,
                                                        final Pattern topicPattern); synchronized final TopologyBuilder addSink(final String name, final String topic, final String... parentNames); synchronized final TopologyBuilder addSink(final String name, final String topic, final StreamPartitioner partitioner, final String... parentNames); synchronized final TopologyBuilder addSink(final String name, final String topic, final Serializer keySerializer, final Serializer valSerializer, final String... parentNames); synchronized final TopologyBuilder addSink(final String name, final String topic, final Serializer<K> keySerializer, final Serializer<V> valSerializer, final StreamPartitioner<? super K, ? super V> partitioner, final String... parentNames); synchronized final TopologyBuilder addProcessor(final String name, final ProcessorSupplier supplier, final String... parentNames); synchronized final TopologyBuilder addStateStore(final StateStoreSupplier supplier, final String... processorNames); synchronized final TopologyBuilder connectProcessorAndStateStores(final String processorName, final String... stateStoreNames); synchronized final TopologyBuilder connectProcessors(final String... processorNames); synchronized final TopologyBuilder addInternalTopic(final String topicName); synchronized final TopologyBuilder copartitionSources(final Collection<String> sourceNodes); synchronized Map<Integer, Set<String>> nodeGroups(); synchronized ProcessorTopology build(final Integer topicGroupId); synchronized ProcessorTopology buildGlobalStateTopology(); Map<String, StateStore> globalStateStores(); synchronized Map<Integer, TopicsInfo> topicGroups(); synchronized Pattern earliestResetTopicsPattern(); synchronized Pattern latestResetTopicsPattern(); Map<String, List<String>> stateStoreNameToSourceTopics(); synchronized Collection<Set<String>> copartitionGroups(); SubscriptionUpdates subscriptionUpdates(); synchronized Pattern sourceTopicPattern(); synchronized void updateSubscriptions(final SubscriptionUpdates subscriptionUpdates, final String threadId);  }