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

Class ApacheKafkaOffsetPositionFactory

java.lang.Object

com.linkedin.venice.pubsub.PubSubPositionFactory

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

public class ApacheKafkaOffsetPositionFactory
extends PubSubPositionFactory

A PubSubPositionFactory for creating ApacheKafkaOffsetPosition instances.

This factory handles deserialization of positions backed by Kafka offsets.

Constructor Summary

Constructors

Constructor	Description
ApacheKafkaOffsetPositionFactory(int positionTypeId)

Method Summary

Modifier and Type	Method	Description
PubSubPosition	createFromByteBuffer(ByteBuffer buffer)	Deserializes a PubSubPosition from the given byte buffer.
String	getPubSubPositionClassName()	Returns the fully qualified class name of the PubSubPosition implementation handled by this factory.

Methods inherited from class com.linkedin.venice.pubsub.PubSubPositionFactory

createFromWireFormat, getPositionTypeId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ApacheKafkaOffsetPositionFactory

public ApacheKafkaOffsetPositionFactory(int positionTypeId)

Method Details

createFromByteBuffer

public PubSubPosition createFromByteBuffer(ByteBuffer buffer)

Description copied from class: PubSubPositionFactory

Deserializes a PubSubPosition from the given byte buffer.

Specified by:

createFromByteBuffer in class PubSubPositionFactory

Parameters:

buffer - the byte buffer containing the serialized position

Returns:

a new PubSubPosition instance

getPubSubPositionClassName

public String getPubSubPositionClassName()

Description copied from class: PubSubPositionFactory

Returns the fully qualified class name of the PubSubPosition implementation handled by this factory.

Specified by:

getPubSubPositionClassName in class PubSubPositionFactory

Returns:

the fully qualified class name of the associated position class