Package org.apache.kafka.streams.processor

Class TaskMetadata

java.lang.Object

org.apache.kafka.streams.processor.TaskMetadata

@Deprecated
public class TaskMetadata
extends Object

Deprecated.

since 3.0, use TaskMetadata instead.

Represents the state of a single task running within a KafkaStreams application.

Constructor Summary

Constructors

Constructor	Description
TaskMetadata(String taskId, Set<TopicPartition> topicPartitions, Map<TopicPartition,Long> committedOffsets, Map<TopicPartition,Long> endOffsets, Optional<Long> timeCurrentIdlingStarted)	Deprecated.

Method Summary

Modifier and Type	Method	Description
Map<TopicPartition,Long>	committedOffsets()	Deprecated. This function will return a map of TopicPartitions and the highest committed offset seen so far
Map<TopicPartition,Long>	endOffsets()	Deprecated. This function will return a map of TopicPartitions and the highest offset seen so far in the Topic
boolean	equals(Object o)	Deprecated.
int	hashCode()	Deprecated.
String	taskId()	Deprecated.
Optional<Long>	timeCurrentIdlingStarted()	Deprecated. This function will return the time task idling started, if the task is not currently idling it will return empty
Set<TopicPartition>	topicPartitions()	Deprecated.
String	toString()	Deprecated.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

TaskMetadata

public TaskMetadata(String taskId,
 Set<TopicPartition> topicPartitions,
 Map<TopicPartition,Long> committedOffsets,
 Map<TopicPartition,Long> endOffsets,
 Optional<Long> timeCurrentIdlingStarted)

Deprecated.

Method Details

taskId

public String taskId()

Deprecated.

Returns:

the basic task metadata such as subtopology and partition id

topicPartitions

public Set<TopicPartition> topicPartitions()

Deprecated.

committedOffsets

public Map<TopicPartition,Long> committedOffsets()

Deprecated.

This function will return a map of TopicPartitions and the highest committed offset seen so far

endOffsets

public Map<TopicPartition,Long> endOffsets()

Deprecated.

This function will return a map of TopicPartitions and the highest offset seen so far in the Topic

timeCurrentIdlingStarted

public Optional<Long> timeCurrentIdlingStarted()

Deprecated.

This function will return the time task idling started, if the task is not currently idling it will return empty

equals

public boolean equals(Object o)

Deprecated.

Overrides:

equals in class Object

hashCode

public int hashCode()

Deprecated.

Overrides:

hashCode in class Object

toString

public String toString()

Deprecated.

Overrides:

toString in class Object