TaskId (kafka 2.8.1 API)

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 Description

int partition
The ID of the partition.

int topicGroupId
The ID of the topic group.

Constructor Summary

Constructors
Constructor Description

TaskId(int topicGroupId, int partition)

Method Summary

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

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>