Class ProcessorTopology
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.ProcessorTopology
-
public class ProcessorTopology extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description ProcessorTopology(java.util.List<ProcessorNode> processorNodes, java.util.Map<java.lang.String,SourceNode> sourcesByTopic, java.util.Map<java.lang.String,SinkNode> sinksByTopic, java.util.List<StateStore> stateStores, java.util.List<StateStore> globalStateStores, java.util.Map<java.lang.String,java.lang.String> stateStoreToChangelogTopic, java.util.Set<java.lang.String> repartitionTopics)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.List<StateStore>
globalStateStores()
java.util.Set<java.lang.String>
processorConnectedStateStores(java.lang.String processorName)
java.util.List<ProcessorNode>
processors()
SinkNode
sink(java.lang.String topic)
java.util.Set<SinkNode>
sinks()
java.util.Set<java.lang.String>
sinkTopics()
SourceNode
source(java.lang.String topic)
java.util.Set<SourceNode>
sources()
java.util.Set<java.lang.String>
sourceTopics()
java.util.List<StateStore>
stateStores()
java.util.Map<java.lang.String,java.lang.String>
storeToChangelogTopic()
java.lang.String
toString()
Produces a string representation containing useful information this topology starting with the given indent.java.lang.String
toString(java.lang.String indent)
Produces a string representation containing useful information this topology.static ProcessorTopology
with(java.util.List<ProcessorNode> processorNodes, java.util.Map<java.lang.String,SourceNode> sourcesByTopic, java.util.List<StateStore> stateStoresByName, java.util.Map<java.lang.String,java.lang.String> storeToChangelogTopic)
-
-
-
Constructor Detail
-
ProcessorTopology
public ProcessorTopology(java.util.List<ProcessorNode> processorNodes, java.util.Map<java.lang.String,SourceNode> sourcesByTopic, java.util.Map<java.lang.String,SinkNode> sinksByTopic, java.util.List<StateStore> stateStores, java.util.List<StateStore> globalStateStores, java.util.Map<java.lang.String,java.lang.String> stateStoreToChangelogTopic, java.util.Set<java.lang.String> repartitionTopics)
-
-
Method Detail
-
with
public static ProcessorTopology with(java.util.List<ProcessorNode> processorNodes, java.util.Map<java.lang.String,SourceNode> sourcesByTopic, java.util.List<StateStore> stateStoresByName, java.util.Map<java.lang.String,java.lang.String> storeToChangelogTopic)
-
sourceTopics
public java.util.Set<java.lang.String> sourceTopics()
-
source
public SourceNode source(java.lang.String topic)
-
sources
public java.util.Set<SourceNode> sources()
-
sinkTopics
public java.util.Set<java.lang.String> sinkTopics()
-
sink
public SinkNode sink(java.lang.String topic)
-
sinks
public java.util.Set<SinkNode> sinks()
-
processors
public java.util.List<ProcessorNode> processors()
-
stateStores
public java.util.List<StateStore> stateStores()
-
globalStateStores
public java.util.List<StateStore> globalStateStores()
-
storeToChangelogTopic
public java.util.Map<java.lang.String,java.lang.String> storeToChangelogTopic()
-
toString
public java.lang.String toString()
Produces a string representation containing useful information this topology starting with the given indent. This is useful in debugging scenarios.- Overrides:
toString
in classjava.lang.Object
- Returns:
- A string representation of this instance.
-
toString
public java.lang.String toString(java.lang.String indent)
Produces a string representation containing useful information this topology. This is useful in debugging scenarios.- Returns:
- A string representation of this instance.
-
processorConnectedStateStores
public java.util.Set<java.lang.String> processorConnectedStateStores(java.lang.String processorName)
-
-