Package org.apache.kafka.streams.processor.internals.assignment

Class SubscriptionInfo

java.lang.Object

org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfo

public class SubscriptionInfo
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static long	UNKNOWN_OFFSET_SUM

Constructor Summary

Constructors

Constructor	Description
SubscriptionInfo(int version, int latestSupportedVersion, UUID processId, String userEndPoint, Map<TaskId,Long> taskOffsetSums, byte uniqueField)

Method Summary

Modifier and Type	Method	Description
static SubscriptionInfo	decode(ByteBuffer data)
ByteBuffer	encode()
boolean	equals(Object o)
static Set<TaskId>	getActiveTasksFromTaskOffsetSumMap(Map<TaskId,Long> taskOffsetSums)
static Set<TaskId>	getStandbyTasksFromTaskOffsetSumMap(Map<TaskId,Long> taskOffsetSums)
int	hashCode()
int	latestSupportedVersion()
Set<TaskId>	prevTasks()
UUID	processId()
Set<TaskId>	standbyTasks()
Map<TaskId,Long>	taskOffsetSums()
String	toString()
String	userEndPoint()
int	version()

Methods inherited from class java.lang.Object

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

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,
                        UUID processId,
                        String userEndPoint,
                        Map<TaskId,Long> taskOffsetSums,
                        byte uniqueField)

Method Detail

version

public int version()

latestSupportedVersion

public int latestSupportedVersion()

processId

public UUID processId()

prevTasks

public Set<TaskId> prevTasks()

standbyTasks

public Set<TaskId> standbyTasks()

taskOffsetSums

public Map<TaskId,Long> taskOffsetSums()

userEndPoint

public String userEndPoint()

getActiveTasksFromTaskOffsetSumMap

public static Set<TaskId> getActiveTasksFromTaskOffsetSumMap(Map<TaskId,Long> taskOffsetSums)

getStandbyTasksFromTaskOffsetSumMap

public static Set<TaskId> getStandbyTasksFromTaskOffsetSumMap(Map<TaskId,Long> taskOffsetSums)

encode

public ByteBuffer encode()

Throws:

TaskAssignmentException - if method fails to encode the data

decode

public static SubscriptionInfo decode(ByteBuffer data)

Throws:

TaskAssignmentException - if method fails to decode the data

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object