Class SubscriptionInfoData.TaskId
- java.lang.Object
-
- org.apache.kafka.streams.internals.generated.SubscriptionInfoData.TaskId
-
- All Implemented Interfaces:
org.apache.kafka.common.protocol.Message
- Enclosing class:
- SubscriptionInfoData
public static class SubscriptionInfoData.TaskId extends Object implements org.apache.kafka.common.protocol.Message
-
-
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
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SubscriptionInfoData.TaskId
duplicate()
boolean
equals(Object obj)
void
fromStruct(org.apache.kafka.common.protocol.types.Struct struct, short _version)
int
hashCode()
short
highestSupportedVersion()
short
lowestSupportedVersion()
int
partition()
void
read(org.apache.kafka.common.protocol.Readable _readable, short _version)
SubscriptionInfoData.TaskId
setPartition(int v)
SubscriptionInfoData.TaskId
setTopicGroupId(int v)
int
size(org.apache.kafka.common.protocol.ObjectSerializationCache _cache, short _version)
int
topicGroupId()
String
toString()
org.apache.kafka.common.protocol.types.Struct
toStruct(short _version)
List<org.apache.kafka.common.protocol.types.RawTaggedField>
unknownTaggedFields()
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
-
-
Method Detail
-
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
-
duplicate
public SubscriptionInfoData.TaskId duplicate()
- Specified by:
duplicate
in interfaceorg.apache.kafka.common.protocol.Message
-
topicGroupId
public int topicGroupId()
-
partition
public int partition()
-
unknownTaggedFields
public List<org.apache.kafka.common.protocol.types.RawTaggedField> unknownTaggedFields()
- Specified by:
unknownTaggedFields
in interfaceorg.apache.kafka.common.protocol.Message
-
setTopicGroupId
public SubscriptionInfoData.TaskId setTopicGroupId(int v)
-
setPartition
public SubscriptionInfoData.TaskId setPartition(int v)
-
-