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 java.lang.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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description short
apiKey()
SubscriptionInfoData
duplicate()
boolean
equals(java.lang.Object obj)
void
fromStruct(org.apache.kafka.common.protocol.types.Struct struct, short _version)
int
hashCode()
short
highestSupportedVersion()
int
latestSupportedVersion()
short
lowestSupportedVersion()
java.util.List<SubscriptionInfoData.TaskId>
prevTasks()
java.util.UUID
processId()
void
read(org.apache.kafka.common.protocol.Readable _readable, short _version)
SubscriptionInfoData
setLatestSupportedVersion(int v)
SubscriptionInfoData
setPrevTasks(java.util.List<SubscriptionInfoData.TaskId> v)
SubscriptionInfoData
setProcessId(java.util.UUID v)
SubscriptionInfoData
setStandbyTasks(java.util.List<SubscriptionInfoData.TaskId> v)
SubscriptionInfoData
setTaskOffsetSums(java.util.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)
java.util.List<SubscriptionInfoData.TaskId>
standbyTasks()
java.util.List<SubscriptionInfoData.TaskOffsetSum>
taskOffsetSums()
java.lang.String
toString()
org.apache.kafka.common.protocol.types.Struct
toStruct(short _version)
byte
uniqueField()
java.util.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)
-
-
-
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 interfaceorg.apache.kafka.common.protocol.ApiMessage
-
lowestSupportedVersion
public short lowestSupportedVersion()
- Specified by:
lowestSupportedVersion
in interfaceorg.apache.kafka.common.protocol.Message
-
highestSupportedVersion
public short highestSupportedVersion()
- Specified by:
highestSupportedVersion
in interfaceorg.apache.kafka.common.protocol.Message
-
read
public void read(org.apache.kafka.common.protocol.Readable _readable, short _version)
- Specified by:
read
in interfaceorg.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 interfaceorg.apache.kafka.common.protocol.Message
-
fromStruct
public void fromStruct(org.apache.kafka.common.protocol.types.Struct struct, short _version)
- Specified by:
fromStruct
in interfaceorg.apache.kafka.common.protocol.Message
-
toStruct
public org.apache.kafka.common.protocol.types.Struct toStruct(short _version)
- Specified by:
toStruct
in interfaceorg.apache.kafka.common.protocol.Message
-
size
public int size(org.apache.kafka.common.protocol.ObjectSerializationCache _cache, short _version)
- Specified by:
size
in interfaceorg.apache.kafka.common.protocol.Message
-
equals
public boolean equals(java.lang.Object obj)
- Overrides:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
duplicate
public SubscriptionInfoData duplicate()
- Specified by:
duplicate
in interfaceorg.apache.kafka.common.protocol.Message
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
version
public int version()
-
latestSupportedVersion
public int latestSupportedVersion()
-
processId
public java.util.UUID processId()
-
prevTasks
public java.util.List<SubscriptionInfoData.TaskId> prevTasks()
-
standbyTasks
public java.util.List<SubscriptionInfoData.TaskId> standbyTasks()
-
userEndPoint
public byte[] userEndPoint()
-
taskOffsetSums
public java.util.List<SubscriptionInfoData.TaskOffsetSum> taskOffsetSums()
-
uniqueField
public byte uniqueField()
-
unknownTaggedFields
public java.util.List<org.apache.kafka.common.protocol.types.RawTaggedField> unknownTaggedFields()
- Specified by:
unknownTaggedFields
in interfaceorg.apache.kafka.common.protocol.Message
-
setVersion
public SubscriptionInfoData setVersion(int v)
-
setLatestSupportedVersion
public SubscriptionInfoData setLatestSupportedVersion(int v)
-
setProcessId
public SubscriptionInfoData setProcessId(java.util.UUID v)
-
setPrevTasks
public SubscriptionInfoData setPrevTasks(java.util.List<SubscriptionInfoData.TaskId> v)
-
setStandbyTasks
public SubscriptionInfoData setStandbyTasks(java.util.List<SubscriptionInfoData.TaskId> v)
-
setUserEndPoint
public SubscriptionInfoData setUserEndPoint(byte[] v)
-
setTaskOffsetSums
public SubscriptionInfoData setTaskOffsetSums(java.util.List<SubscriptionInfoData.TaskOffsetSum> v)
-
setUniqueField
public SubscriptionInfoData setUniqueField(byte v)
-
-