Package org.apache.kafka.clients.admin

Class StreamsGroupDescription

java.lang.Object

org.apache.kafka.clients.admin.StreamsGroupDescription

@Evolving
public class StreamsGroupDescription
extends Object

A detailed description of a single streams group in the cluster.

Constructor Summary

Constructors

Constructor	Description
StreamsGroupDescription(String groupId, int groupEpoch, int targetAssignmentEpoch, int topologyEpoch, Collection<StreamsGroupSubtopologyDescription> subtopologies, Collection<StreamsGroupMemberDescription> members, GroupState groupState, Node coordinator, Set<AclOperation> authorizedOperations)

Method Summary

Modifier and Type	Method	Description
Set<AclOperation>	authorizedOperations()	authorizedOperations for this group, or null if that information is not known.
Node	coordinator()	The group coordinator, or null if the coordinator is not known.
boolean	equals(Object o)
int	groupEpoch()	The epoch of the consumer group.
String	groupId()	The id of the streams group.
GroupState	groupState()	The state of the streams group, or UNKNOWN if the state is too new for us to parse.
int	hashCode()
Collection<StreamsGroupMemberDescription>	members()	A list of the members of the streams group.
Collection<StreamsGroupSubtopologyDescription>	subtopologies()	A list of the subtopologies in the streams group.
int	targetAssignmentEpoch()	The epoch of the target assignment.
int	topologyEpoch()	The epoch of the currently used topology.
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

StreamsGroupDescription

public StreamsGroupDescription(String groupId,
 int groupEpoch,
 int targetAssignmentEpoch,
 int topologyEpoch,
 Collection<StreamsGroupSubtopologyDescription> subtopologies,
 Collection<StreamsGroupMemberDescription> members,
 GroupState groupState,
 Node coordinator,
 Set<AclOperation> authorizedOperations)

Method Details

groupId

public String groupId()

The id of the streams group.

groupEpoch

public int groupEpoch()

The epoch of the consumer group.

targetAssignmentEpoch

public int targetAssignmentEpoch()

The epoch of the target assignment.

topologyEpoch

public int topologyEpoch()

The epoch of the currently used topology.

members

public Collection<StreamsGroupMemberDescription> members()

A list of the members of the streams group.

subtopologies

public Collection<StreamsGroupSubtopologyDescription> subtopologies()

A list of the subtopologies in the streams group.

groupState

public GroupState groupState()

The state of the streams group, or UNKNOWN if the state is too new for us to parse.

coordinator

public Node coordinator()

The group coordinator, or null if the coordinator is not known.

authorizedOperations

public Set<AclOperation> authorizedOperations()

authorizedOperations for this group, or null if that information is not known.

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