org.apache.kafka.clients.admin.StreamsGroupSubtopologyDescription

@Evolvingpublic class StreamsGroupSubtopologyDescriptionextends Object

A detailed description of a subtopology in a streams group.

Nested Class Summary
Nested Classes
Modifier and Type
Class
Description
static class
StreamsGroupSubtopologyDescription.TopicInfo
Information about a topic.
Constructor Summary
Constructors
Constructor
Description
StreamsGroupSubtopologyDescription(String subtopologyId, List<String> sourceTopics, List<String> repartitionSinkTopics, Map<String, StreamsGroupSubtopologyDescription.TopicInfo> stateChangelogTopics, Map<String, StreamsGroupSubtopologyDescription.TopicInfo> repartitionSourceTopics)
Method Summary
Modifier and Type
Method
Description
boolean
equals(Object o)

int
hashCode()

List<String>
repartitionSinkTopics()
The repartition topics the topology writes to.
Map<String, StreamsGroupSubtopologyDescription.TopicInfo>
repartitionSourceTopics()
The set of source topics that are internally created repartition topics.
List<String>
sourceTopics()
The topics the topology reads from.
Map<String, StreamsGroupSubtopologyDescription.TopicInfo>
stateChangelogTopics()
The set of state changelog topics associated with this subtopology.
String
subtopologyId()
String to uniquely identify the subtopology.
String
toString()

Methods inherited from class java.lang.Object
getClass, notify, notifyAll, wait, wait, wait

Constructor Details
- StreamsGroupSubtopologyDescription
  public StreamsGroupSubtopologyDescription(String subtopologyId, List<String> sourceTopics, List<String> repartitionSinkTopics, Map<String, StreamsGroupSubtopologyDescription.TopicInfo> stateChangelogTopics, Map<String, StreamsGroupSubtopologyDescription.TopicInfo> repartitionSourceTopics)
Method Details
- subtopologyId
  public String subtopologyId()
  String to uniquely identify the subtopology.
- sourceTopics
  public List<String> sourceTopics()
  The topics the topology reads from.
- repartitionSinkTopics
  public List<String> repartitionSinkTopics()
  The repartition topics the topology writes to.
- stateChangelogTopics
  public Map<String, StreamsGroupSubtopologyDescription.TopicInfo> stateChangelogTopics()
  The set of state changelog topics associated with this subtopology.
- repartitionSourceTopics
  public Map<String, StreamsGroupSubtopologyDescription.TopicInfo> repartitionSourceTopics()
  The set of source topics that are internally created repartition topics.
- 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

Class StreamsGroupSubtopologyDescription

Nested Class Summary