Package org.apache.kafka.streams

Interface TopologyDescription.Node

All Known Subinterfaces:

TopologyDescription.Processor, TopologyDescription.Sink, TopologyDescription.Source

Enclosing interface:

TopologyDescription

public static interface TopologyDescription.Node

A node of a topology. Can be a source, sink, or processor node.

Method Summary

Modifier and Type	Method	Description
java.lang.String	name()	The name of the node.
java.util.Set<TopologyDescription.Node>	predecessors()	The predecessors of this node within a sub-topology.
java.util.Set<TopologyDescription.Node>	successors()	The successor of this node within a sub-topology.

Method Detail

name

java.lang.String name()

The name of the node. Will never be null.

Returns:

the name of the node

predecessors

java.util.Set<TopologyDescription.Node> predecessors()

The predecessors of this node within a sub-topology. Note, sources do not have any predecessors. Will never be null.

Returns:

set of all predecessors

successors

java.util.Set<TopologyDescription.Node> successors()

The successor of this node within a sub-topology. Note, sinks do not have any successors. Will never be null.

Returns:

set of all successor