...
Code Block | ||||
---|---|---|---|---|
| ||||
class TaskMetadata { /** * @deprecated since 3.0, pleasenot useintended thefor constructor that accepts a TaskId object instead of a Stringpublic use */ @Deprecated public TaskMetadata(final String taskId, final Set<TopicPartition> topicPartitions, final Map<TopicPartition, Long> committedOffsets, final Map<TopicPartition, Long> endOffsets, final Optional<Long> timeCurrentIdlingStarted); // new public TaskMetadata(final TaskId 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(); } } |
...