Class TopicPartitionWithOffset

java.lang.Object

io.confluent.kafkarest.entities.TopicPartitionWithOffset

public abstract class TopicPartitionWithOffset
extends Object

Represents a TopicPartition with its associated offset and metadata.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TopicPartitionWithOffset.Builder

Method Summary

Modifier and Type	Method	Description
static TopicPartitionWithOffset.Builder	builder()
static TopicPartitionWithOffset	fromOffsetAndMetadata(org.apache.kafka.common.TopicPartition topicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata offsetAndMetadata)
static TopicPartitionWithOffset	fromSharePartitionOffsetInfo(org.apache.kafka.common.TopicPartition topicPartition, org.apache.kafka.clients.admin.SharePartitionOffsetInfo sharePartitionOffsetInfo)
abstract Long	getOffset()
abstract org.apache.kafka.common.TopicPartition	getTopicPartition()

Methods inherited from class java.lang.Object

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

Method Details

getTopicPartition

public abstract org.apache.kafka.common.TopicPartition getTopicPartition()

getOffset

@Nullable
public abstract Long getOffset()

builder

public static TopicPartitionWithOffset.Builder builder()

fromOffsetAndMetadata

public static TopicPartitionWithOffset fromOffsetAndMetadata(org.apache.kafka.common.TopicPartition topicPartition,
 org.apache.kafka.clients.consumer.OffsetAndMetadata offsetAndMetadata)

fromSharePartitionOffsetInfo

public static TopicPartitionWithOffset fromSharePartitionOffsetInfo(org.apache.kafka.common.TopicPartition topicPartition,
 org.apache.kafka.clients.admin.SharePartitionOffsetInfo sharePartitionOffsetInfo)