THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
class TaskMetadata {
public TaskMetadata(final TaskId taskId, // changed from String to TaskId
final Set<TopicPartition> topicPartitions,
final Map<TopicPartition, Long> committedOffsets,
final Map<TopicPartition, Long> endOffsets,
final Optional<Long> timeCurrentIdlingStarted);
/**
* @return the basic task metadata such as subtopology and partition id
*/
public TaskId getTaskId() {
return taskId;
}
/**
* @return the basic task metadata such as subtopology and partition id
* @deprecated please use {@link #getTaskId()} instead.
*/
@Deprecated
public String taskId() {
return taskId.toString();
}
} |
...