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