public interface Task
Modifier and Type | Method and Description |
---|---|
java.lang.String |
applicationId() |
java.util.Collection<org.apache.kafka.common.TopicPartition> |
changelogPartitions() |
void |
close(boolean clean,
boolean isZombie) |
void |
closeSuspended(boolean clean,
boolean isZombie,
java.lang.RuntimeException e) |
void |
commit() |
boolean |
commitNeeded() |
ProcessorContext |
context() |
StateStore |
getStore(java.lang.String name) |
boolean |
hasStateStores() |
TaskId |
id() |
boolean |
initializeStateStores()
Initialize the task and return
true if the task is ready to run, i.e, it has not state stores |
void |
initializeTopology() |
java.util.Set<org.apache.kafka.common.TopicPartition> |
partitions() |
void |
resume() |
void |
suspend() |
ProcessorTopology |
topology() |
java.lang.String |
toString(java.lang.String indent) |
boolean initializeStateStores()
true
if the task is ready to run, i.e, it has not state storesjava.lang.IllegalStateException
- If store gets registered after initialized is already finishedStreamsException
- if the store's change log does not contain the partitionboolean commitNeeded()
void initializeTopology()
void commit()
void suspend()
void resume()
void closeSuspended(boolean clean, boolean isZombie, java.lang.RuntimeException e)
void close(boolean clean, boolean isZombie)
StateStore getStore(java.lang.String name)
java.lang.String applicationId()
ProcessorTopology topology()
ProcessorContext context()
TaskId id()
java.util.Set<org.apache.kafka.common.TopicPartition> partitions()
java.util.Collection<org.apache.kafka.common.TopicPartition> changelogPartitions()
boolean hasStateStores()
java.lang.String toString(java.lang.String indent)