public class InternalTopologyBuilder
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
InternalTopologyBuilder.AbstractNode |
static class |
InternalTopologyBuilder.GlobalStore |
static class |
InternalTopologyBuilder.Processor |
static class |
InternalTopologyBuilder.Sink |
static class |
InternalTopologyBuilder.Source |
static class |
InternalTopologyBuilder.StateStoreFactory |
static class |
InternalTopologyBuilder.SubscriptionUpdates
Used to capture subscribed topic via Patterns discovered during the
partition assignment process.
|
static class |
InternalTopologyBuilder.Subtopology |
static class |
InternalTopologyBuilder.TopicsInfo |
static class |
InternalTopologyBuilder.TopologyDescription |
Constructor and Description |
---|
InternalTopologyBuilder() |
Modifier and Type | Method and Description |
---|---|
void |
addGlobalStore(StoreBuilder<KeyValueStore> storeBuilder,
java.lang.String sourceName,
TimestampExtractor timestampExtractor,
org.apache.kafka.common.serialization.Deserializer keyDeserializer,
org.apache.kafka.common.serialization.Deserializer valueDeserializer,
java.lang.String topic,
java.lang.String processorName,
ProcessorSupplier stateUpdateSupplier) |
void |
addInternalTopic(java.lang.String topicName) |
void |
addProcessor(java.lang.String name,
ProcessorSupplier supplier,
java.lang.String... predecessorNames) |
<K,V> void |
addSink(java.lang.String name,
java.lang.String topic,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valSerializer,
StreamPartitioner<? super K,? super V> partitioner,
java.lang.String... predecessorNames) |
<K,V> void |
addSink(java.lang.String name,
TopicNameExtractor<K,V> topicExtractor,
org.apache.kafka.common.serialization.Serializer<K> keySerializer,
org.apache.kafka.common.serialization.Serializer<V> valSerializer,
StreamPartitioner<? super K,? super V> partitioner,
java.lang.String... predecessorNames) |
void |
addSource(Topology.AutoOffsetReset offsetReset,
java.lang.String name,
TimestampExtractor timestampExtractor,
org.apache.kafka.common.serialization.Deserializer keyDeserializer,
org.apache.kafka.common.serialization.Deserializer valDeserializer,
java.util.regex.Pattern topicPattern) |
void |
addSource(Topology.AutoOffsetReset offsetReset,
java.lang.String name,
TimestampExtractor timestampExtractor,
org.apache.kafka.common.serialization.Deserializer keyDeserializer,
org.apache.kafka.common.serialization.Deserializer valDeserializer,
java.lang.String... topics) |
void |
addStateStore(StoreBuilder storeBuilder,
boolean allowOverride,
java.lang.String... processorNames) |
void |
addStateStore(StoreBuilder storeBuilder,
java.lang.String... processorNames) |
java.util.Set<java.lang.String> |
allStateStoreName() |
ProcessorTopology |
build() |
ProcessorTopology |
build(java.lang.Integer topicGroupId) |
ProcessorTopology |
buildGlobalStateTopology()
Builds the topology for any global state stores
|
void |
connectProcessorAndStateStores(java.lang.String processorName,
java.lang.String... stateStoreNames) |
java.util.Collection<java.util.Set<java.lang.String>> |
copartitionGroups() |
void |
copartitionSources(java.util.Collection<java.lang.String> sourceNodes) |
InternalTopologyBuilder.TopologyDescription |
describe() |
java.util.regex.Pattern |
earliestResetTopicsPattern() |
java.util.Set<java.lang.String> |
getSourceTopicNames() |
java.util.Map<java.lang.String,InternalTopologyBuilder.StateStoreFactory> |
getStateStores() |
java.util.Map<java.lang.String,StateStore> |
globalStateStores()
Get any global
StateStore s that are part of the
topology |
java.util.regex.Pattern |
latestResetTopicsPattern() |
void |
markSourceStoreAndTopic(StoreBuilder storeBuilder,
java.lang.String topic) |
java.util.Map<java.lang.Integer,java.util.Set<java.lang.String>> |
nodeGroups() |
InternalTopologyBuilder |
rewriteTopology(StreamsConfig config) |
InternalTopologyBuilder |
setApplicationIdAndInternalStream(java.lang.String applicationId,
java.lang.String internalStream,
java.lang.String internalStreamCompacted) |
void |
setDefaultStream(java.lang.String defaultStream) |
java.util.regex.Pattern |
sourceTopicPattern() |
java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
stateStoreNameToSourceTopics() |
InternalTopologyBuilder.SubscriptionUpdates |
subscriptionUpdates() |
java.util.Map<java.lang.Integer,InternalTopologyBuilder.TopicsInfo> |
topicGroups()
Returns the map of topic groups keyed by the group id.
|
void |
updateSubscribedTopics(java.util.Set<java.lang.String> topics,
java.lang.String logPrefix) |
public final InternalTopologyBuilder setApplicationIdAndInternalStream(java.lang.String applicationId, java.lang.String internalStream, java.lang.String internalStreamCompacted)
public final InternalTopologyBuilder rewriteTopology(StreamsConfig config)
public final void setDefaultStream(java.lang.String defaultStream)
public final void addSource(Topology.AutoOffsetReset offsetReset, java.lang.String name, TimestampExtractor timestampExtractor, org.apache.kafka.common.serialization.Deserializer keyDeserializer, org.apache.kafka.common.serialization.Deserializer valDeserializer, java.lang.String... topics)
public final void addSource(Topology.AutoOffsetReset offsetReset, java.lang.String name, TimestampExtractor timestampExtractor, org.apache.kafka.common.serialization.Deserializer keyDeserializer, org.apache.kafka.common.serialization.Deserializer valDeserializer, java.util.regex.Pattern topicPattern)
public final <K,V> void addSink(java.lang.String name, java.lang.String topic, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valSerializer, StreamPartitioner<? super K,? super V> partitioner, java.lang.String... predecessorNames)
public final <K,V> void addSink(java.lang.String name, TopicNameExtractor<K,V> topicExtractor, org.apache.kafka.common.serialization.Serializer<K> keySerializer, org.apache.kafka.common.serialization.Serializer<V> valSerializer, StreamPartitioner<? super K,? super V> partitioner, java.lang.String... predecessorNames)
public final void addProcessor(java.lang.String name, ProcessorSupplier supplier, java.lang.String... predecessorNames)
public final void addStateStore(StoreBuilder storeBuilder, java.lang.String... processorNames)
public final void addStateStore(StoreBuilder storeBuilder, boolean allowOverride, java.lang.String... processorNames)
public final void addGlobalStore(StoreBuilder<KeyValueStore> storeBuilder, java.lang.String sourceName, TimestampExtractor timestampExtractor, org.apache.kafka.common.serialization.Deserializer keyDeserializer, org.apache.kafka.common.serialization.Deserializer valueDeserializer, java.lang.String topic, java.lang.String processorName, ProcessorSupplier stateUpdateSupplier)
public final void connectProcessorAndStateStores(java.lang.String processorName, java.lang.String... stateStoreNames)
public final void markSourceStoreAndTopic(StoreBuilder storeBuilder, java.lang.String topic)
public final void addInternalTopic(java.lang.String topicName)
public final void copartitionSources(java.util.Collection<java.lang.String> sourceNodes)
public java.util.Map<java.lang.Integer,java.util.Set<java.lang.String>> nodeGroups()
public ProcessorTopology build()
public ProcessorTopology build(java.lang.Integer topicGroupId)
public ProcessorTopology buildGlobalStateTopology()
public java.util.Map<java.lang.String,StateStore> globalStateStores()
StateStore
s that are part of the
topologyStateStore
spublic java.util.Set<java.lang.String> allStateStoreName()
public java.util.Map<java.lang.Integer,InternalTopologyBuilder.TopicsInfo> topicGroups()
public java.util.regex.Pattern earliestResetTopicsPattern()
public java.util.regex.Pattern latestResetTopicsPattern()
public java.util.Map<java.lang.String,java.util.List<java.lang.String>> stateStoreNameToSourceTopics()
public java.util.Collection<java.util.Set<java.lang.String>> copartitionGroups()
public InternalTopologyBuilder.SubscriptionUpdates subscriptionUpdates()
public java.util.regex.Pattern sourceTopicPattern()
public InternalTopologyBuilder.TopologyDescription describe()
public void updateSubscribedTopics(java.util.Set<java.lang.String> topics, java.lang.String logPrefix)
public java.util.Set<java.lang.String> getSourceTopicNames()
public java.util.Map<java.lang.String,InternalTopologyBuilder.StateStoreFactory> getStateStores()