Package org.apache.kafka.streams.processor

Class TaskId

java.lang.Object

org.apache.kafka.streams.processor.TaskId

All Implemented Interfaces:

Comparable<TaskId>

public class TaskId
extends Object
implements Comparable<TaskId>

The task ID representation composed as subtopology (aka topicGroupId) plus the assigned partition ID.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	NAMED_TOPOLOGY_DELIMITER
final int	partition	Deprecated.
final int	topicGroupId	Deprecated.

Constructor Summary

Constructors

Constructor	Description
TaskId(int topicGroupId, int partition)
TaskId(int topicGroupId, int partition, String topologyName)

Method Summary

Modifier and Type	Method	Description
int	compareTo(TaskId other)
boolean	equals(Object o)
int	hashCode()
static TaskId	parse(String taskIdStr)
int	partition()
static TaskId	readFrom(DataInputStream in, int version)	Deprecated. since 3.0, for internal use, will be removed
static TaskId	readFrom(ByteBuffer buf, int version)	Deprecated. since 3.0, for internal use, will be removed
int	subtopology()
String	topologyName()	Experimental feature -- will return null
String	toString()
void	writeTo(DataOutputStream out, int version)	Deprecated. since 3.0, for internal use, will be removed
void	writeTo(ByteBuffer buf, int version)	Deprecated. since 3.0, for internal use, will be removed

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

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 Details

TaskId

public TaskId(int topicGroupId,
 int partition)

TaskId

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

Method Details

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>