Field Detail

• NAMED_TOPOLOGY_DELIMITER

  public static final String NAMED_TOPOLOGY_DELIMITER

  See Also:

  Constant Field Values

• topicGroupId

  @Deprecated
  public final int topicGroupId

  Deprecated. 
  The ID of the subtopology, aka topicGroupId.

• partition

  @Deprecated
  public final int partition

  Deprecated. 
  The ID of the partition.

Constructor Detail

• TaskId

  public TaskId(int topicGroupId,
                int partition)

• TaskId

  public TaskId(int topicGroupId,
                int partition,
                String topologyName)

Method Detail

• subtopology

  public int subtopology()

• partition

  public int partition()

• topologyName

  public String topologyName()

  Experimental feature -- will return null

• toString

  public String toString()

  Overrides:

  toString in class Object

• parse

  public static TaskId parse(String taskIdStr)

  Throws:

  TaskIdFormatException - if the taskIdStr is not a valid TaskId

• writeTo

  @Deprecated
  public void writeTo(DataOutputStream out,
                                  int version)
                           throws IOException

  Deprecated. since 3.0, for internal use, will be removed

  Throws:

  IOException - if cannot write to output stream

• readFrom

  @Deprecated
  public static TaskId readFrom(DataInputStream in,
                                            int version)
                                     throws IOException

  Deprecated. since 3.0, for internal use, will be removed

  Throws:

  IOException - if cannot read from input stream

• writeTo

  @Deprecated
  public void writeTo(ByteBuffer buf,
                                  int version)

  Deprecated. since 3.0, for internal use, will be removed

• readFrom

  @Deprecated
  public static TaskId readFrom(ByteBuffer buf,
                                            int version)

  Deprecated. since 3.0, for internal use, will be removed

• equals

  public boolean equals(Object o)

  Overrides:

  equals in class Object

• hashCode

  public int hashCode()

  Overrides:

  hashCode in class Object

• compareTo

  public int compareTo(TaskId other)

  Specified by:

  compareTo in interface Comparable<TaskId>