Class TaskManager
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.TaskManager
-
public class TaskManager extends java.lang.Object
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Set<TaskId>
cachedTasksIds()
Returns ids of tasks whose states are kept on the local storage.java.util.Set<TaskId>
prevActiveTaskIds()
java.util.UUID
processId()
void
setAssignmentMetadata(java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> activeTasks, java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks)
void
setClusterMetadata(org.apache.kafka.common.Cluster cluster)
void
setPartitionsByHostState(java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsByHostState)
java.lang.String
toString()
Produces a string representation containing useful information about the TaskManager.java.lang.String
toString(java.lang.String indent)
void
updateSubscriptionsFromAssignment(java.util.List<org.apache.kafka.common.TopicPartition> partitions)
void
updateSubscriptionsFromMetadata(java.util.Set<java.lang.String> topics)
-
-
-
Method Detail
-
prevActiveTaskIds
public java.util.Set<TaskId> prevActiveTaskIds()
-
cachedTasksIds
public java.util.Set<TaskId> cachedTasksIds()
Returns ids of tasks whose states are kept on the local storage.
-
processId
public java.util.UUID processId()
-
setClusterMetadata
public void setClusterMetadata(org.apache.kafka.common.Cluster cluster)
-
setPartitionsByHostState
public void setPartitionsByHostState(java.util.Map<HostInfo,java.util.Set<org.apache.kafka.common.TopicPartition>> partitionsByHostState)
-
setAssignmentMetadata
public void setAssignmentMetadata(java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> activeTasks, java.util.Map<TaskId,java.util.Set<org.apache.kafka.common.TopicPartition>> standbyTasks)
-
updateSubscriptionsFromAssignment
public void updateSubscriptionsFromAssignment(java.util.List<org.apache.kafka.common.TopicPartition> partitions)
-
updateSubscriptionsFromMetadata
public void updateSubscriptionsFromMetadata(java.util.Set<java.lang.String> topics)
-
toString
public java.lang.String toString()
Produces a string representation containing useful information about the TaskManager. This is useful in debugging scenarios.- Overrides:
toString
in classjava.lang.Object
- Returns:
- A string representation of the TaskManager instance.
-
toString
public java.lang.String toString(java.lang.String indent)
-
-