com.github.jcustenborder.kafka.connect.utils.data

Class SinkOffsetState

java.lang.Object

com.github.jcustenborder.kafka.connect.utils.data.SinkOffsetState

All Implemented Interfaces:

Comparable<SinkOffsetState>

public class SinkOffsetState
extends Object
implements Comparable<SinkOffsetState>

This class is a helper class for storing offsets for a topic partition in an external store. Many connectors implement exactly once features against by storing the last offset for each of the topic partitions they have processed.

Method Summary

Modifier and Type	Method and Description
int	compareTo(SinkOffsetState that)
boolean	equals(Object obj)
int	hashCode()
static SinkOffsetState	of(String topic, int partition, long offset)
static SinkOffsetState	of(org.apache.kafka.common.TopicPartition topicPartition, long offset)
Long	offset()
Integer	partition()
String	topic()
org.apache.kafka.common.TopicPartition	topicPartition()
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

topic

public String topic()

partition

public Integer partition()

offset

public Long offset()

topicPartition

public org.apache.kafka.common.TopicPartition topicPartition()

of

public static SinkOffsetState of(org.apache.kafka.common.TopicPartition topicPartition,
                                 long offset)

of

public static SinkOffsetState of(String topic,
                                 int partition,
                                 long offset)

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

compareTo

public int compareTo(SinkOffsetState that)

Specified by:

compareTo in interface Comparable<SinkOffsetState>