Page History

/**
 * 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    return topicGroupId;
int partition();

	/**
    }

 * Experimental feature public-- intwill partition()return {null
     */
   return partition;
public    }String namedTopology();

    /**
     * @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);
}