public interface TopologyDescriptiontopology. The nodes of a topology are grouped into sub-topologies if they are connected. In contrast, two sub-topologies are not connected but can be linked to each other via topics, i.e., if one sub-topology writes into a topic and another sub-topology reads from the same topic. Message ProcessorContext.forward(Record, String) forwards} using custom Processors and Transformers are not considered in the topology graph.
When KafkaStreams.start() is called, different sub-topologies will be constructed and executed as independent tasks.
| Modifier and Type | Interface and Description |
|---|---|
static interface | TopologyDescription.GlobalStoreRepresents a global store. |
static interface | TopologyDescription.NodeA node of a topology. |
static interface | TopologyDescription.ProcessorA processor node of a topology. |
static interface | TopologyDescription.SinkA sink node of a topology. |
static interface | TopologyDescription.SourceA source node of a topology. |
static interface | TopologyDescription.SubtopologyA connected sub-graph of a Topology. |
| Modifier and Type | Method and Description |
|---|---|
Set<TopologyDescription.GlobalStore> | globalStores()All global stores of the represented topology. |
Set<TopologyDescription.Subtopology> | subtopologies()All sub-topologies of the represented topology. |
Set<TopologyDescription.Subtopology> subtopologies()
Set<TopologyDescription.GlobalStore> globalStores()