Package com.linkedin.venice.pubsub.adapter.kafka.common

Class ApacheKafkaOffsetPosition

java.lang.Object

com.linkedin.venice.pubsub.adapter.kafka.common.ApacheKafkaOffsetPosition

All Implemented Interfaces:

Measurable, PubSubPosition

public class ApacheKafkaOffsetPosition
extends Object
implements PubSubPosition

Offset position for Apache Kafka topics

Field Summary

Fields inherited from interface com.linkedin.venice.pubsub.api.PubSubPosition

PUBSUB_POSITION_WIRE_FORMAT_SERIALIZER

Constructor Summary

Constructors

Constructor	Description
ApacheKafkaOffsetPosition(long offset)
ApacheKafkaOffsetPosition(ByteBuffer buffer)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object other)
Class<? extends PubSubPositionFactory>	getFactoryClass()	Returns the factory class responsible for creating this position type.
int	getHeapSize()
long	getInternalOffset()
long	getNumericOffset()
PubSubPositionWireFormat	getPositionWireFormat()	Returns an Avro-encoded wire format representation of this position, including both the position type ID and the raw Avro-encoded bytes representing the position value.
int	hashCode()
static ApacheKafkaOffsetPosition	of(long offset)
static ApacheKafkaOffsetPosition	of(ByteBuffer buffer)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.venice.pubsub.api.PubSubPosition

getFactoryClassName, isSymbolic, toWireFormatBuffer, toWireFormatBytes

Constructor Details

ApacheKafkaOffsetPosition

public ApacheKafkaOffsetPosition(long offset)

ApacheKafkaOffsetPosition

public ApacheKafkaOffsetPosition(ByteBuffer buffer)
                          throws IOException

Parameters:

buffer - the buffer to read from. The ByteBuffer expected to contain avro serialized long

Throws:

IOException - if the buffer is not a valid avro serialized long

Method Details

getInternalOffset

public long getInternalOffset()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object other)

Specified by:

equals in interface PubSubPosition

Overrides:

equals in class Object

hashCode

public int hashCode()

Specified by:

hashCode in interface PubSubPosition

Overrides:

hashCode in class Object

getNumericOffset

public long getNumericOffset()

Specified by:

getNumericOffset in interface PubSubPosition

of

public static ApacheKafkaOffsetPosition of(long offset)

of

public static ApacheKafkaOffsetPosition of(ByteBuffer buffer)
                                    throws IOException

Throws:

IOException

getPositionWireFormat

public PubSubPositionWireFormat getPositionWireFormat()

Returns an Avro-encoded wire format representation of this position, including both the position type ID and the raw Avro-encoded bytes representing the position value. This is used to transmit PubSubPosition instances over the wire.

Example (ApacheKafkaOffsetPosition):

 +-------------------------+
 | Avro-encoded int: type  |  (e.g., 0)
 +-------------------------+
 | Avro-encoded bytes:     |  (Avro-encoded long offset)
 |   rawBytes              |
 +-------------------------+
 

Specified by:

getPositionWireFormat in interface PubSubPosition

Returns:

the serialized PubSubPositionWireFormat containing the type and position bytes

getFactoryClass

public Class<? extends PubSubPositionFactory> getFactoryClass()

Description copied from interface: PubSubPosition

Returns the factory class responsible for creating this position type. This enables strong type checking and reflection-based instantiation without requiring the actual factory instance to be returned.

Specified by:

getFactoryClass in interface PubSubPosition

Returns:

the class object of the factory that can construct this position

getHeapSize

public int getHeapSize()

Specified by:

getHeapSize in interface Measurable