Class ClientState
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.assignment.ClientState
-
public class ClientState extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description static java.util.Comparator<org.apache.kafka.common.TopicPartition>
TOPIC_PARTITION_COMPARATOR
-
Constructor Summary
Constructors Constructor Description ClientState()
ClientState(java.util.Set<TaskId> previousActiveTasks, java.util.Set<TaskId> previousStandbyTasks, java.util.Map<TaskId,java.lang.Long> taskLagTotals, int capacity)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
activeTaskCount()
java.util.Set<TaskId>
activeTasks()
void
addOwnedPartitions(java.util.Collection<org.apache.kafka.common.TopicPartition> ownedPartitions, java.lang.String consumer)
void
addPreviousTasksAndOffsetSums(java.lang.String consumerId, java.util.Map<TaskId,java.lang.Long> taskOffsetSums)
void
assignActive(TaskId task)
void
assignActiveTasks(java.util.Collection<TaskId> tasks)
int
assignedTaskCount()
void
assignStandby(TaskId task)
void
computeTaskLags(java.util.UUID uuid, java.util.Map<TaskId,java.lang.Long> allTaskEndOffsetSums)
Compute the lag for each stateful task, including tasks this client did not previously have.ClientState
copy()
void
incrementCapacity()
void
initializePrevTasks(java.util.Map<org.apache.kafka.common.TopicPartition,TaskId> taskForPartitionMap)
long
lagFor(TaskId task)
Returns the total lag across all logged stores in the task.java.lang.String
previousOwnerForPartition(org.apache.kafka.common.TopicPartition partition)
java.util.Set<TaskId>
previousTasksForConsumer(java.lang.String memberId)
java.util.Set<TaskId>
standbyTasks()
java.util.Set<TaskId>
statefulActiveTasks()
java.util.Set<TaskId>
statelessActiveTasks()
java.lang.String
toString()
void
unassignActive(TaskId task)
-
-
-
Method Detail
-
copy
public ClientState copy()
-
incrementCapacity
public void incrementCapacity()
-
activeTasks
public java.util.Set<TaskId> activeTasks()
-
activeTaskCount
public int activeTaskCount()
-
assignActiveTasks
public void assignActiveTasks(java.util.Collection<TaskId> tasks)
-
assignActive
public void assignActive(TaskId task)
-
unassignActive
public void unassignActive(TaskId task)
-
standbyTasks
public java.util.Set<TaskId> standbyTasks()
-
assignStandby
public void assignStandby(TaskId task)
-
assignedTaskCount
public int assignedTaskCount()
-
previousOwnerForPartition
public java.lang.String previousOwnerForPartition(org.apache.kafka.common.TopicPartition partition)
-
addOwnedPartitions
public void addOwnedPartitions(java.util.Collection<org.apache.kafka.common.TopicPartition> ownedPartitions, java.lang.String consumer)
-
addPreviousTasksAndOffsetSums
public void addPreviousTasksAndOffsetSums(java.lang.String consumerId, java.util.Map<TaskId,java.lang.Long> taskOffsetSums)
-
initializePrevTasks
public void initializePrevTasks(java.util.Map<org.apache.kafka.common.TopicPartition,TaskId> taskForPartitionMap)
-
computeTaskLags
public void computeTaskLags(java.util.UUID uuid, java.util.Map<TaskId,java.lang.Long> allTaskEndOffsetSums)
Compute the lag for each stateful task, including tasks this client did not previously have.
-
lagFor
public long lagFor(TaskId task)
Returns the total lag across all logged stores in the task. Equal to the end offset sum if this client did not have any state for this task on disk.- Returns:
- end offset sum - offset sum Task.LATEST_OFFSET if this was previously an active running task on this client
-
statefulActiveTasks
public java.util.Set<TaskId> statefulActiveTasks()
-
statelessActiveTasks
public java.util.Set<TaskId> statelessActiveTasks()
-
previousTasksForConsumer
public java.util.Set<TaskId> previousTasksForConsumer(java.lang.String memberId)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-