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 long
UNKNOWN_OFFSET_SUM
-
Constructor Summary
Constructors Constructor Description SubscriptionInfo(int version, int latestSupportedVersion, java.util.UUID processId, java.lang.String userEndPoint, java.util.Map<TaskId,java.lang.Long> taskOffsetSums, byte uniqueField)
-
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()
boolean
equals(java.lang.Object o)
static java.util.Set<TaskId>
getActiveTasksFromTaskOffsetSumMap(java.util.Map<TaskId,java.lang.Long> taskOffsetSums)
static java.util.Set<TaskId>
getStandbyTasksFromTaskOffsetSumMap(java.util.Map<TaskId,java.lang.Long> taskOffsetSums)
int
hashCode()
int
latestSupportedVersion()
java.util.Set<TaskId>
prevTasks()
java.util.UUID
processId()
java.util.Set<TaskId>
standbyTasks()
java.util.Map<TaskId,java.lang.Long>
taskOffsetSums()
java.lang.String
toString()
java.lang.String
userEndPoint()
int
version()
-
-
-
Field Detail
-
UNKNOWN_OFFSET_SUM
public static final long UNKNOWN_OFFSET_SUM
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
SubscriptionInfo
public SubscriptionInfo(int version, int latestSupportedVersion, java.util.UUID processId, java.lang.String userEndPoint, java.util.Map<TaskId,java.lang.Long> taskOffsetSums, byte uniqueField)
-
-
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()
-
taskOffsetSums
public java.util.Map<TaskId,java.lang.Long> taskOffsetSums()
-
userEndPoint
public java.lang.String userEndPoint()
-
getActiveTasksFromTaskOffsetSumMap
public static java.util.Set<TaskId> getActiveTasksFromTaskOffsetSumMap(java.util.Map<TaskId,java.lang.Long> taskOffsetSums)
-
getStandbyTasksFromTaskOffsetSumMap
public static java.util.Set<TaskId> getStandbyTasksFromTaskOffsetSumMap(java.util.Map<TaskId,java.lang.Long> taskOffsetSums)
-
encode
public java.nio.ByteBuffer encode()
- Throws:
TaskAssignmentException
- if method fails to encode the data
-
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
-
-