Package org.apache.kafka.streams.internals.generated

Class SubscriptionInfoData

java.lang.Object

org.apache.kafka.streams.internals.generated.SubscriptionInfoData

All Implemented Interfaces:

org.apache.kafka.common.protocol.ApiMessage, org.apache.kafka.common.protocol.Message

public class SubscriptionInfoData
extends Object
implements org.apache.kafka.common.protocol.ApiMessage

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SubscriptionInfoData.PartitionToOffsetSum
static class	SubscriptionInfoData.TaskId
static class	SubscriptionInfoData.TaskOffsetSum

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.kafka.common.protocol.types.Schema	SCHEMA_1
static org.apache.kafka.common.protocol.types.Schema	SCHEMA_2
static org.apache.kafka.common.protocol.types.Schema	SCHEMA_3
static org.apache.kafka.common.protocol.types.Schema	SCHEMA_4
static org.apache.kafka.common.protocol.types.Schema	SCHEMA_5
static org.apache.kafka.common.protocol.types.Schema	SCHEMA_6
static org.apache.kafka.common.protocol.types.Schema	SCHEMA_7
static org.apache.kafka.common.protocol.types.Schema	SCHEMA_8
static org.apache.kafka.common.protocol.types.Schema[]	SCHEMAS

Constructor Summary

Constructors

Constructor	Description
SubscriptionInfoData()
SubscriptionInfoData(org.apache.kafka.common.protocol.Readable _readable, short _version)
SubscriptionInfoData(org.apache.kafka.common.protocol.types.Struct _struct, short _version)

Method Summary

Modifier and Type	Method	Description
short	apiKey()
SubscriptionInfoData	duplicate()
boolean	equals(Object obj)
void	fromStruct(org.apache.kafka.common.protocol.types.Struct struct, short _version)
int	hashCode()
short	highestSupportedVersion()
int	latestSupportedVersion()
short	lowestSupportedVersion()
List<SubscriptionInfoData.TaskId>	prevTasks()
UUID	processId()
void	read(org.apache.kafka.common.protocol.Readable _readable, short _version)
SubscriptionInfoData	setLatestSupportedVersion(int v)
SubscriptionInfoData	setPrevTasks(List<SubscriptionInfoData.TaskId> v)
SubscriptionInfoData	setProcessId(UUID v)
SubscriptionInfoData	setStandbyTasks(List<SubscriptionInfoData.TaskId> v)
SubscriptionInfoData	setTaskOffsetSums(List<SubscriptionInfoData.TaskOffsetSum> v)
SubscriptionInfoData	setUniqueField(byte v)
SubscriptionInfoData	setUserEndPoint(byte[] v)
SubscriptionInfoData	setVersion(int v)
int	size(org.apache.kafka.common.protocol.ObjectSerializationCache _cache, short _version)
List<SubscriptionInfoData.TaskId>	standbyTasks()
List<SubscriptionInfoData.TaskOffsetSum>	taskOffsetSums()
String	toString()
org.apache.kafka.common.protocol.types.Struct	toStruct(short _version)
byte	uniqueField()
List<org.apache.kafka.common.protocol.types.RawTaggedField>	unknownTaggedFields()
byte[]	userEndPoint()
int	version()
void	write(org.apache.kafka.common.protocol.Writable _writable, org.apache.kafka.common.protocol.ObjectSerializationCache _cache, short _version)

Methods inherited from class java.lang.Object

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

Field Detail

SCHEMA_1

public static final org.apache.kafka.common.protocol.types.Schema SCHEMA_1

SCHEMA_2

public static final org.apache.kafka.common.protocol.types.Schema SCHEMA_2

SCHEMA_3

public static final org.apache.kafka.common.protocol.types.Schema SCHEMA_3

SCHEMA_4

public static final org.apache.kafka.common.protocol.types.Schema SCHEMA_4

SCHEMA_5

public static final org.apache.kafka.common.protocol.types.Schema SCHEMA_5

SCHEMA_6

public static final org.apache.kafka.common.protocol.types.Schema SCHEMA_6

SCHEMA_7

public static final org.apache.kafka.common.protocol.types.Schema SCHEMA_7

SCHEMA_8

public static final org.apache.kafka.common.protocol.types.Schema SCHEMA_8

SCHEMAS

public static final org.apache.kafka.common.protocol.types.Schema[] SCHEMAS

Constructor Detail

SubscriptionInfoData

public SubscriptionInfoData(org.apache.kafka.common.protocol.Readable _readable,
                            short _version)

SubscriptionInfoData

public SubscriptionInfoData(org.apache.kafka.common.protocol.types.Struct _struct,
                            short _version)

SubscriptionInfoData

public SubscriptionInfoData()

Method Detail

apiKey

public short apiKey()

Specified by:

apiKey in interface org.apache.kafka.common.protocol.ApiMessage

lowestSupportedVersion

public short lowestSupportedVersion()

Specified by:

lowestSupportedVersion in interface org.apache.kafka.common.protocol.Message

highestSupportedVersion

public short highestSupportedVersion()

Specified by:

highestSupportedVersion in interface org.apache.kafka.common.protocol.Message

read

public void read(org.apache.kafka.common.protocol.Readable _readable,
                 short _version)

Specified by:

read in interface org.apache.kafka.common.protocol.Message

write

public void write(org.apache.kafka.common.protocol.Writable _writable,
                  org.apache.kafka.common.protocol.ObjectSerializationCache _cache,
                  short _version)

Specified by:

write in interface org.apache.kafka.common.protocol.Message

fromStruct

public void fromStruct(org.apache.kafka.common.protocol.types.Struct struct,
                       short _version)

Specified by:

fromStruct in interface org.apache.kafka.common.protocol.Message

toStruct

public org.apache.kafka.common.protocol.types.Struct toStruct(short _version)

Specified by:

toStruct in interface org.apache.kafka.common.protocol.Message

size

public int size(org.apache.kafka.common.protocol.ObjectSerializationCache _cache,
                short _version)

Specified by:

size in interface org.apache.kafka.common.protocol.Message

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

duplicate

public SubscriptionInfoData duplicate()

Specified by:

duplicate in interface org.apache.kafka.common.protocol.Message

toString

public String toString()

Overrides:

toString in class Object

version

public int version()

latestSupportedVersion

public int latestSupportedVersion()

processId

public UUID processId()

prevTasks

public List<SubscriptionInfoData.TaskId> prevTasks()

standbyTasks

public List<SubscriptionInfoData.TaskId> standbyTasks()

userEndPoint

public byte[] userEndPoint()

taskOffsetSums

public List<SubscriptionInfoData.TaskOffsetSum> taskOffsetSums()

uniqueField

public byte uniqueField()

unknownTaggedFields

public List<org.apache.kafka.common.protocol.types.RawTaggedField> unknownTaggedFields()

Specified by:

unknownTaggedFields in interface org.apache.kafka.common.protocol.Message

setVersion

public SubscriptionInfoData setVersion(int v)

setLatestSupportedVersion

public SubscriptionInfoData setLatestSupportedVersion(int v)

setProcessId

public SubscriptionInfoData setProcessId(UUID v)

setPrevTasks

public SubscriptionInfoData setPrevTasks(List<SubscriptionInfoData.TaskId> v)

setStandbyTasks

public SubscriptionInfoData setStandbyTasks(List<SubscriptionInfoData.TaskId> v)

setUserEndPoint

public SubscriptionInfoData setUserEndPoint(byte[] v)

setTaskOffsetSums

public SubscriptionInfoData setTaskOffsetSums(List<SubscriptionInfoData.TaskOffsetSum> v)

setUniqueField

public SubscriptionInfoData setUniqueField(byte v)