Package org.apache.kafka.streams

Interface TopologyDescription

public interface TopologyDescription

A meta representation of a topology.

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.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	TopologyDescription.GlobalStore	Represents a global store.
static interface	TopologyDescription.Node	A node of a topology.
static interface	TopologyDescription.Processor	A processor node of a topology.
static interface	TopologyDescription.Sink	A sink node of a topology.
static interface	TopologyDescription.Source	A source node of a topology.
static interface	TopologyDescription.Subtopology	A connected sub-graph of a Topology.

Method Summary

Modifier and Type	Method	Description
Set<TopologyDescription.GlobalStore>	globalStores()	All global stores of the represented topology.
Set<TopologyDescription.Subtopology>	subtopologies()	All sub-topologies of the represented topology.

Method Details

subtopologies

Set<TopologyDescription.Subtopology> subtopologies()

All sub-topologies of the represented topology.

Returns:

set of all sub-topologies

globalStores

Set<TopologyDescription.GlobalStore> globalStores()

All global stores of the represented topology.

Returns:

set of all global stores