reactor.kafka.receiver

Interface ReceiverPartition

public interface ReceiverPartition

Topic partition interface that supports seek operations that can be invoked when partitions are assigned.

Method Summary

Modifier and Type	Method and Description
default Long	beginningOffset() Return the beginning offset for this partition.
default Long	endOffset() Return the end offset for this partition.
long	position() Returns the offset of the next record that will be fetched from this topic partition.
void	seek(long offset) Seeks to the specified offset of the topic partition.
void	seekToBeginning() Seeks to the first available offset of the topic partition.
void	seekToEnd() Seeks to the last offset of the topic partition.
void	seekToTimestamp(long timestamp) Seek to the topic partition offset that is greater than or equal to the timestamp.
org.apache.kafka.common.TopicPartition	topicPartition() Returns the underlying Kafka topic partition.

Method Detail

topicPartition

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

Returns the underlying Kafka topic partition.

Returns:

topic partition

seekToBeginning

void seekToBeginning()

Seeks to the first available offset of the topic partition. This overrides the offset starting from which records are fetched.

seekToEnd

void seekToEnd()

Seeks to the last offset of the topic partition. This overrides the offset starting from which records are fetched.

seek

void seek(long offset)

Seeks to the specified offset of the topic partition. This overrides the offset starting from which records are fetched.

seekToTimestamp

void seekToTimestamp(long timestamp)

Seek to the topic partition offset that is greater than or equal to the timestamp. If there are no matching records, seekToEnd() is performed. See Consumer.offsetsForTimes(java.util.Map).

Parameters:

timestamp - the timestamp.

Since:

1.3.5

position

long position()

Returns the offset of the next record that will be fetched from this topic partition.

Returns:

current offset of this partition

beginningOffset

@Nullable
default Long beginningOffset()

Return the beginning offset for this partition.

Returns:

the offset.

Since:

1.3.19

See Also:

Consumer.beginningOffsets(java.util.Collection)

endOffset

@Nullable
default Long endOffset()

Return the end offset for this partition.

Returns:

the offset.

Since:

1.3.19

See Also:

Consumer.endOffsets(java.util.Collection)