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 and Description
static String	NAMED_TOPOLOGY_DELIMITER
int	partition Deprecated.
int	topicGroupId Deprecated.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
int	compareTo(TaskId other)
boolean	equals(Object o)
int	hashCode()
static TaskId	parse(String taskIdStr)
int	partition()
static TaskId	readFrom(ByteBuffer buf, int version) Deprecated. since 3.0, for internal use, will be removed
static TaskId	readFrom(DataInputStream in, 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(ByteBuffer buf, int version) Deprecated. since 3.0, for internal use, will be removed
void	writeTo(DataOutputStream out, 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 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>