Package org.apache.kafka.clients.admin

Class StreamsGroupMemberAssignment

java.lang.Object

org.apache.kafka.clients.admin.StreamsGroupMemberAssignment

@Evolving
public class StreamsGroupMemberAssignment
extends Object

A description of the assignments of a specific group member.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StreamsGroupMemberAssignment.TaskIds	All tasks for one subtopology of a member.

Constructor Summary

Constructors

Constructor	Description
StreamsGroupMemberAssignment(List<StreamsGroupMemberAssignment.TaskIds> activeTasks, List<StreamsGroupMemberAssignment.TaskIds> standbyTasks, List<StreamsGroupMemberAssignment.TaskIds> warmupTasks)

Method Summary

Modifier and Type	Method	Description
List<StreamsGroupMemberAssignment.TaskIds>	activeTasks()	Active tasks for this client.
boolean	equals(Object o)
int	hashCode()
List<StreamsGroupMemberAssignment.TaskIds>	standbyTasks()	Standby tasks for this client.
String	toString()
List<StreamsGroupMemberAssignment.TaskIds>	warmupTasks()	Warmup tasks for this client.

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

StreamsGroupMemberAssignment

public StreamsGroupMemberAssignment(List<StreamsGroupMemberAssignment.TaskIds> activeTasks,
 List<StreamsGroupMemberAssignment.TaskIds> standbyTasks,
 List<StreamsGroupMemberAssignment.TaskIds> warmupTasks)

Method Details

activeTasks

public List<StreamsGroupMemberAssignment.TaskIds> activeTasks()

Active tasks for this client.

standbyTasks

public List<StreamsGroupMemberAssignment.TaskIds> standbyTasks()

Standby tasks for this client.

warmupTasks

public List<StreamsGroupMemberAssignment.TaskIds> warmupTasks()

Warmup tasks for this client.

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