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 plus the assigned partition ID.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	NAMED_TOPOLOGY_DELIMITER

Constructor Summary

Constructors

Constructor	Description
TaskId(int subtopology, int partition)
TaskId(int subtopology, 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()
int	subtopology()
String	topologyName()	Experimental feature -- will return null
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Field Details

NAMED_TOPOLOGY_DELIMITER

public static final String NAMED_TOPOLOGY_DELIMITER

See Also:

• Constant Field Values

Constructor Details

TaskId

public TaskId(int subtopology,
 int partition)

TaskId

public TaskId(int subtopology,
 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

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>