Class StreamsGroupMemberDescription

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