Class AbstractTask
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.AbstractTask
-
- All Implemented Interfaces:
Task
- Direct Known Subclasses:
StandbyTask
,StreamTask
public abstract class AbstractTask extends java.lang.Object implements Task
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long>
activeTaskCheckpointableOffsets()
java.lang.String
applicationId()
java.util.Collection<org.apache.kafka.common.TopicPartition>
changelogPartitions()
boolean
commitNeeded()
ProcessorContext
context()
StateStore
getStore(java.lang.String name)
boolean
hasStateStores()
TaskId
id()
boolean
isClosed()
boolean
isEosEnabled()
java.util.Set<org.apache.kafka.common.TopicPartition>
partitions()
ProcessorTopology
topology()
java.lang.String
toString()
Produces a string representation containing useful information about a Task.java.lang.String
toString(java.lang.String indent)
Produces a string representation containing useful information about a Task starting with the given indent.protected void
updateOffsetLimits()
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.kafka.streams.processor.internals.Task
close, closeSuspended, commit, initializeStateStores, initializeTopology, resume, suspend
-
-
-
-
Method Detail
-
applicationId
public java.lang.String applicationId()
- Specified by:
applicationId
in interfaceTask
-
partitions
public java.util.Set<org.apache.kafka.common.TopicPartition> partitions()
- Specified by:
partitions
in interfaceTask
-
topology
public ProcessorTopology topology()
-
context
public ProcessorContext context()
-
getStore
public StateStore getStore(java.lang.String name)
-
toString
public java.lang.String toString()
Produces a string representation containing useful information about a Task. This is useful in debugging scenarios.- Overrides:
toString
in classjava.lang.Object
- Returns:
- A string representation of the StreamTask instance.
-
isEosEnabled
public boolean isEosEnabled()
-
toString
public java.lang.String toString(java.lang.String indent)
Produces a string representation containing useful information about a Task starting with the given indent. This is useful in debugging scenarios.
-
activeTaskCheckpointableOffsets
protected java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> activeTaskCheckpointableOffsets()
-
updateOffsetLimits
protected void updateOffsetLimits()
-
isClosed
public boolean isClosed()
-
commitNeeded
public boolean commitNeeded()
- Specified by:
commitNeeded
in interfaceTask
-
hasStateStores
public boolean hasStateStores()
- Specified by:
hasStateStores
in interfaceTask
-
changelogPartitions
public java.util.Collection<org.apache.kafka.common.TopicPartition> changelogPartitions()
- Specified by:
changelogPartitions
in interfaceTask
- Returns:
- any changelog partitions associated with this task
-
-