Class TaskId
java.lang.Object
org.apache.kafka.streams.processor.TaskId
- All Implemented Interfaces:
Comparable<TaskId>
The task ID representation composed as subtopology plus the assigned partition ID.
Field Summary
FieldsConstructor Summary
ConstructorsMethod Summary
Field Details
NAMED_TOPOLOGY_DELIMITER
- See Also:
Constructor Details
TaskId
public TaskId(int subtopology, int partition) TaskId
Method Details
subtopology
public int subtopology()partition
public int partition()topologyName
Experimental feature -- will return nulltoString
parse
- Throws:
TaskIdFormatException- if the taskIdStr is not a validTaskId
equals
hashCode
compareTo
- Specified by:
compareToin interfaceComparable<TaskId>