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 Details

    • name

      String name()
      The name of the node. Will never be null.
      Returns:
      the name of the node

    • predecessors

      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

      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