THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
/** * The task ID representation composed as subtopology (aka topic group ID) plus the assigned partition ID. */ public class TaskId { /** The ID of the subtopology, aka topicGroupId. */ @Deprecated public final int topicGroupId; /** The ID of the partition. */ @Deprecated public final int partition; public int subtopology(); public int partition(); /** * Experimental feature -- will return null */ public String namedTopologytopologyName(); /** * @deprecated since 3.0, for internal use, will be removed */ @Deprecated public void writeTo(final DataOutputStream out, final int version); /** * @deprecated since 3.0, for internal use, will be removed */ @Deprecated public static TaskId readFrom(final DataInputStream in, final int version); /** * @deprecated since 3.0, for internal use, will be removed */ @Deprecated public void writeTo(final ByteBuffer buf, final int version); /** * @deprecated since 3.0, for internal use, will be removed */ @Deprecated public static TaskId readFrom(final ByteBuffer buf, final int version); } |
...