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

Field Summary

Fields

Modifier and Type	Field and Description
int	partition The ID of the partition.
int	topicGroupId The ID of the topic group.

Constructor Summary

Constructors

Constructor and Description
TaskId(int topicGroupId, int partition)

Method Summary

Modifier and Type	Method and Description
int	compareTo(TaskId other)
boolean	equals(Object o)
int	hashCode()
static TaskId	parse(String taskIdStr)
static TaskId	readFrom(ByteBuffer buf)
static TaskId	readFrom(DataInputStream in)
String	toString()
void	writeTo(ByteBuffer buf)
void	writeTo(DataOutputStream out)

Methods inherited from class java.lang.Object

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

Field Detail

topicGroupId

public final int topicGroupId

The ID of the topic group.

partition

public final int partition

The ID of the partition.

Constructor Detail

TaskId

public TaskId(int topicGroupId,
              int partition)

Method Detail

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

public void writeTo(DataOutputStream out)
             throws IOException

Throws:

IOException - if cannot write to output stream

readFrom

public static TaskId readFrom(DataInputStream in)
                       throws IOException

Throws:

IOException - if cannot read from input stream

writeTo

public void writeTo(ByteBuffer buf)

readFrom

public static TaskId readFrom(ByteBuffer buf)

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>