org.apache.kafka.streams

Interface TaskMetadata

public interface TaskMetadata

Metadata of a task.

Method Summary

Modifier and Type	Method and Description
Map<org.apache.kafka.common.TopicPartition,Long>	committedOffsets() Offsets of the source topic partitions committed so far by the task.
Map<org.apache.kafka.common.TopicPartition,Long>	endOffsets() End offsets of the source topic partitions of the task.
boolean	equals(Object o) Compares the specified object with this TaskMetadata.
int	hashCode() Returns the hash code value for this TaskMetadata.
TaskId	taskId() Task ID of the task.
Optional<Long>	timeCurrentIdlingStarted() Time task idling started.
Set<org.apache.kafka.common.TopicPartition>	topicPartitions() Source topic partitions of the task.

Method Detail

taskId

TaskId taskId()

Task ID of the task.

Returns:

task ID consisting of subtopology and partition ID

topicPartitions

Set<org.apache.kafka.common.TopicPartition> topicPartitions()

Source topic partitions of the task.

Returns:

source topic partitions

committedOffsets

Map<org.apache.kafka.common.TopicPartition,Long> committedOffsets()

Offsets of the source topic partitions committed so far by the task.

Returns:

map from source topic partitions to committed offsets

endOffsets

Map<org.apache.kafka.common.TopicPartition,Long> endOffsets()

End offsets of the source topic partitions of the task.

Returns:

map source topic partition to end offsets

timeCurrentIdlingStarted

Optional<Long> timeCurrentIdlingStarted()

Time task idling started. If the task is not currently idling it will return empty.

Returns:

time when task idling started, empty Optional if the task is currently not idling

equals

boolean equals(Object o)

Compares the specified object with this TaskMetadata. Returns true if and only if the specified object is also a TaskMetadata and both taskId() and topicPartitions() are equal.

Overrides:

equals in class Object

Returns:

true if this object is the same as the obj argument; false otherwise.

hashCode

int hashCode()

Returns the hash code value for this TaskMetadata. The hash code of a list is defined to be the result of the following calculation:

 
 Objects.hash(taskId(), topicPartitions());
 
 

Overrides:

hashCode in class Object

Returns:

a hash code value for this object.