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 and 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 and Description
Set<TopologyDescription.GlobalStore>	globalStores() All global stores of the represented topology.
Set<TopologyDescription.Subtopology>	subtopologies() All sub-topologies of the represented topology.

Method Detail

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