Package org.apache.kafka.streams

Interface TopologyDescription.Subtopology

Enclosing interface:
TopologyDescription
public static interface TopologyDescription.Subtopology
A connected sub-graph of a Topology.

Nodes of a Subtopology are connected directly or indirectly via state stores (i.e., if multiple processors share the same state).

  • Method Summary

    Modifier and Type Method Description
    int id()
    Internally assigned unique ID.
    Set<TopologyDescription.Node> nodes()
    All nodes of this sub-topology.

  • Method Details

    • id

      int id()
      Internally assigned unique ID.
      Returns:
      the ID of the sub-topology

    • nodes

      Set<TopologyDescription.Node> nodes()
      All nodes of this sub-topology.
      Returns:
      set of all nodes within the sub-topology