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