Class TaskId
- java.lang.Object
-
- org.apache.kafka.streams.processor.TaskId
-
-
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(java.lang.Object o)
int
hashCode()
static TaskId
parse(java.lang.String taskIdStr)
static TaskId
readFrom(java.io.DataInputStream in)
static TaskId
readFrom(java.nio.ByteBuffer buf)
java.lang.String
toString()
void
writeTo(java.io.DataOutputStream out)
void
writeTo(java.nio.ByteBuffer buf)
-
-
-
Method Detail
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
parse
public static TaskId parse(java.lang.String taskIdStr)
- Throws:
TaskIdFormatException
- if the taskIdStr is not a validTaskId
-
writeTo
public void writeTo(java.io.DataOutputStream out) throws java.io.IOException
- Throws:
java.io.IOException
- if cannot write to output stream
-
readFrom
public static TaskId readFrom(java.io.DataInputStream in) throws java.io.IOException
- Throws:
java.io.IOException
- if cannot read from input stream
-
writeTo
public void writeTo(java.nio.ByteBuffer buf)
-
readFrom
public static TaskId readFrom(java.nio.ByteBuffer buf)
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
-