org.springframework.kafka.support

Class TopicPartitionInitialOffset

java.lang.Object

org.springframework.kafka.support.TopicPartitionInitialOffset

public class TopicPartitionInitialOffset
extends java.lang.Object

A configuration container to represent a topic name, partition number and, optionally, an initial offset for it. The initial offset can be:

• null - do nothing;
• positive (including 0) - seek to the absolute offset within the partition;
• negative - seek to the offset relative to the current last offset within the partition: consumer.seekToEnd() + initialOffset.

Offsets are applied when the container is start()ed.

Author:

Artem Bilan

Constructor Summary

Constructors

Constructor and Description
TopicPartitionInitialOffset(java.lang.String topic, int partition)
TopicPartitionInitialOffset(java.lang.String topic, int partition, java.lang.Long initialOffset)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
int	hashCode()
java.lang.Long	initialOffset()
int	partition()
java.lang.String	topic()
org.apache.kafka.common.TopicPartition	topicPartition()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TopicPartitionInitialOffset

public TopicPartitionInitialOffset(java.lang.String topic,
                                   int partition)

TopicPartitionInitialOffset

public TopicPartitionInitialOffset(java.lang.String topic,
                                   int partition,
                                   java.lang.Long initialOffset)

Method Detail

topicPartition

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

partition

public int partition()

topic

public java.lang.String topic()

initialOffset

public java.lang.Long initialOffset()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object