Package org.apache.kafka.clients.admin

Class StreamsGroupMemberDescription

java.lang.Object

org.apache.kafka.clients.admin.StreamsGroupMemberDescription

@Evolving
public class StreamsGroupMemberDescription
extends Object

A detailed description of a single streams groups member in the cluster.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamsGroupMemberDescription.Endpoint	The user-defined endpoint for the member.
static class	StreamsGroupMemberDescription.TaskOffset	The cumulative offset for one task.

Constructor Summary

Constructors

Constructor

Description

StreamsGroupMemberDescription(String memberId, int memberEpoch, Optional<String> instanceId, Optional<String> rackId, String clientId, String clientHost, int topologyEpoch, String processId, Optional<StreamsGroupMemberDescription.Endpoint> userEndpoint, Map<String,String> clientTags, List<StreamsGroupMemberDescription.TaskOffset> taskOffsets, List<StreamsGroupMemberDescription.TaskOffset> taskEndOffsets, StreamsGroupMemberAssignment assignment, StreamsGroupMemberAssignment targetAssignment, boolean isClassic)

Method Summary

Modifier and Type	Method	Description
StreamsGroupMemberAssignment	assignment()	The current assignment.
String	clientHost()	The host of the group member.
String	clientId()	The client ID of the group member.
Map<String,String>	clientTags()	Used for rack-aware assignment algorithm.
boolean	equals(Object o)
int	hashCode()
Optional<String>	instanceId()	The id of the instance, used for static membership, if available.
boolean	isClassic()	The flag indicating whether a member is classic.
int	memberEpoch()	The epoch of the group member.
String	memberId()	The id of the group member.
String	processId()	Identity of the streams instance that may have multiple clients.
Optional<String>	rackId()	The rack ID of the group member.
StreamsGroupMemberAssignment	targetAssignment()	The target assignment.
List<StreamsGroupMemberDescription.TaskOffset>	taskEndOffsets()	Cumulative task changelog end offsets for tasks.
List<StreamsGroupMemberDescription.TaskOffset>	taskOffsets()	Cumulative offsets for tasks.
int	topologyEpoch()	The epoch of the topology present on the client.
String	toString()
Optional<StreamsGroupMemberDescription.Endpoint>	userEndpoint()	User-defined endpoint for Interactive Queries.

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

StreamsGroupMemberDescription

public StreamsGroupMemberDescription(String memberId,
 int memberEpoch,
 Optional<String> instanceId,
 Optional<String> rackId,
 String clientId,
 String clientHost,
 int topologyEpoch,
 String processId,
 Optional<StreamsGroupMemberDescription.Endpoint> userEndpoint,
 Map<String,String> clientTags,
 List<StreamsGroupMemberDescription.TaskOffset> taskOffsets,
 List<StreamsGroupMemberDescription.TaskOffset> taskEndOffsets,
 StreamsGroupMemberAssignment assignment,
 StreamsGroupMemberAssignment targetAssignment,
 boolean isClassic)

Method Details

memberId

public String memberId()

The id of the group member.

memberEpoch

public int memberEpoch()

The epoch of the group member.

instanceId

public Optional<String> instanceId()

The id of the instance, used for static membership, if available.

rackId

public Optional<String> rackId()

The rack ID of the group member.

clientId

public String clientId()

The client ID of the group member.

clientHost

public String clientHost()

The host of the group member.

topologyEpoch

public int topologyEpoch()

The epoch of the topology present on the client.

processId

public String processId()

Identity of the streams instance that may have multiple clients.

userEndpoint

public Optional<StreamsGroupMemberDescription.Endpoint> userEndpoint()

User-defined endpoint for Interactive Queries.

clientTags

public Map<String,String> clientTags()

Used for rack-aware assignment algorithm.

taskOffsets

public List<StreamsGroupMemberDescription.TaskOffset> taskOffsets()

Cumulative offsets for tasks.

taskEndOffsets

public List<StreamsGroupMemberDescription.TaskOffset> taskEndOffsets()

Cumulative task changelog end offsets for tasks.

assignment

public StreamsGroupMemberAssignment assignment()

The current assignment.

targetAssignment

public StreamsGroupMemberAssignment targetAssignment()

The target assignment.

isClassic

public boolean isClassic()

The flag indicating whether a member is classic.

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