Class StreamsGroupTopologyDescription

java.lang.Object

org.apache.kafka.clients.admin.StreamsGroupTopologyDescription

@Public
@Evolving
public class StreamsGroupTopologyDescription
extends Object

A description of a Kafka Streams topology, as recorded by the topology description plugin configured on the broker.

This type mirrors org.apache.kafka.streams.TopologyDescription in shape but lives in the admin client so that callers do not need to depend on kafka-streams. The wire format only carries the successor relation between nodes; the predecessors are reconstructed from the successors when this description is built.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamsGroupTopologyDescription.GlobalStore	A global state store, made up of a StreamsGroupTopologyDescription.Source node and the StreamsGroupTopologyDescription.Processor node that maintains the store.
static interface	StreamsGroupTopologyDescription.Node	A node of a topology.
static final class	StreamsGroupTopologyDescription.Processor	A processor node of a topology.
static final class	StreamsGroupTopologyDescription.Sink	A sink node of a topology.
static final class	StreamsGroupTopologyDescription.Source	A source node of a topology.
static class	StreamsGroupTopologyDescription.Subtopology	A connected sub-graph of a topology.

Constructor Summary

Constructors

Constructor	Description
StreamsGroupTopologyDescription(Collection<StreamsGroupTopologyDescription.Subtopology> subtopologies, Collection<StreamsGroupTopologyDescription.GlobalStore> globalStores)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
Collection<StreamsGroupTopologyDescription.GlobalStore>	globalStores()	The global state stores used by this topology.
int	hashCode()
Collection<StreamsGroupTopologyDescription.Subtopology>	subtopologies()	The subtopologies that make up this topology.
String	toString()

Methods inherited from class Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

StreamsGroupTopologyDescription

public StreamsGroupTopologyDescription(Collection<StreamsGroupTopologyDescription.Subtopology> subtopologies,
 Collection<StreamsGroupTopologyDescription.GlobalStore> globalStores)

Method Details

subtopologies

public Collection<StreamsGroupTopologyDescription.Subtopology> subtopologies()

The subtopologies that make up this topology.

globalStores

public Collection<StreamsGroupTopologyDescription.GlobalStore> globalStores()

The global state stores used by this topology.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object