Class SubscriptionInfo
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfo
-
public class SubscriptionInfo extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description static int
LATEST_SUPPORTED_VERSION
-
Constructor Summary
Constructors Modifier Constructor Description protected
SubscriptionInfo(int version, int latestSupportedVersion, java.util.UUID processId, java.util.Set<TaskId> prevTasks, java.util.Set<TaskId> standbyTasks, java.lang.String userEndPoint)
SubscriptionInfo(int version, java.util.UUID processId, java.util.Set<TaskId> prevTasks, java.util.Set<TaskId> standbyTasks, java.lang.String userEndPoint)
SubscriptionInfo(java.util.UUID processId, java.util.Set<TaskId> prevTasks, java.util.Set<TaskId> standbyTasks, java.lang.String userEndPoint)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static SubscriptionInfo
decode(java.nio.ByteBuffer data)
java.nio.ByteBuffer
encode()
protected void
encodeClientUUID(java.nio.ByteBuffer buf)
protected void
encodeTasks(java.nio.ByteBuffer buf, java.util.Collection<TaskId> taskIds)
protected void
encodeUserEndPoint(java.nio.ByteBuffer buf, byte[] endPointBytes)
boolean
equals(java.lang.Object o)
protected int
getVersionThreeAndFourByteLength(byte[] endPointBytes)
int
hashCode()
int
latestSupportedVersion()
protected byte[]
prepareUserEndPoint()
java.util.Set<TaskId>
prevTasks()
java.util.UUID
processId()
java.util.Set<TaskId>
standbyTasks()
java.lang.String
toString()
java.lang.String
userEndPoint()
int
version()
-
-
-
Field Detail
-
LATEST_SUPPORTED_VERSION
public static final int LATEST_SUPPORTED_VERSION
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
SubscriptionInfo
public SubscriptionInfo(java.util.UUID processId, java.util.Set<TaskId> prevTasks, java.util.Set<TaskId> standbyTasks, java.lang.String userEndPoint)
-
SubscriptionInfo
public SubscriptionInfo(int version, java.util.UUID processId, java.util.Set<TaskId> prevTasks, java.util.Set<TaskId> standbyTasks, java.lang.String userEndPoint)
-
-
Method Detail
-
version
public int version()
-
latestSupportedVersion
public int latestSupportedVersion()
-
processId
public java.util.UUID processId()
-
prevTasks
public java.util.Set<TaskId> prevTasks()
-
standbyTasks
public java.util.Set<TaskId> standbyTasks()
-
userEndPoint
public java.lang.String userEndPoint()
-
encode
public java.nio.ByteBuffer encode()
- Throws:
TaskAssignmentException
- if method fails to encode the data
-
encodeClientUUID
protected void encodeClientUUID(java.nio.ByteBuffer buf)
-
encodeTasks
protected void encodeTasks(java.nio.ByteBuffer buf, java.util.Collection<TaskId> taskIds)
-
prepareUserEndPoint
protected byte[] prepareUserEndPoint()
-
encodeUserEndPoint
protected void encodeUserEndPoint(java.nio.ByteBuffer buf, byte[] endPointBytes)
-
getVersionThreeAndFourByteLength
protected int getVersionThreeAndFourByteLength(byte[] endPointBytes)
-
decode
public static SubscriptionInfo decode(java.nio.ByteBuffer data)
- Throws:
TaskAssignmentException
- if method fails to decode the data
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-