Package org.apache.kafka.clients.consumer.internals.events

Class ListOffsetsApplicationEvent

java.lang.Object

org.apache.kafka.clients.consumer.internals.events.ApplicationEvent

org.apache.kafka.clients.consumer.internals.events.CompletableApplicationEvent<Map<org.apache.kafka.common.TopicPartition,OffsetAndTimestamp>>

org.apache.kafka.clients.consumer.internals.events.ListOffsetsApplicationEvent

All Implemented Interfaces:

CompletableEvent<Map<org.apache.kafka.common.TopicPartition,OffsetAndTimestamp>>

public class ListOffsetsApplicationEvent
extends CompletableApplicationEvent<Map<org.apache.kafka.common.TopicPartition,OffsetAndTimestamp>>

Event for retrieving partition offsets by performing a ListOffsetsRequest. This event is created with a map of TopicPartition and target timestamps to search offsets for. It is completed with the map of TopicPartition and OffsetAndTimestamp found (offset of the first message whose timestamp is greater than or equals to the target timestamp)

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.kafka.clients.consumer.internals.events.ApplicationEvent

ApplicationEvent.Type

Constructor Summary

Constructors

Constructor	Description
ListOffsetsApplicationEvent(Map<org.apache.kafka.common.TopicPartition,Long> timestampToSearch, boolean requireTimestamps)

Method Summary

Modifier and Type	Method	Description
Map<org.apache.kafka.common.TopicPartition,OffsetAndTimestamp>	emptyResult()	Build result representing that no offsets were found as part of the current event.
boolean	equals(Object o)
int	hashCode()
boolean	requireTimestamps()
Map<org.apache.kafka.common.TopicPartition,Long>	timestampsToSearch()
String	toString()

Methods inherited from class org.apache.kafka.clients.consumer.internals.events.CompletableApplicationEvent

chain, future, get, toStringBase

Methods inherited from class org.apache.kafka.clients.consumer.internals.events.ApplicationEvent

type

Methods inherited from class java.lang.Object

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

Constructor Details

ListOffsetsApplicationEvent

public ListOffsetsApplicationEvent(Map<org.apache.kafka.common.TopicPartition,Long> timestampToSearch,
 boolean requireTimestamps)

Method Details

emptyResult

public Map<org.apache.kafka.common.TopicPartition,OffsetAndTimestamp> emptyResult()

Build result representing that no offsets were found as part of the current event.

Returns:

Map containing all the partitions the event was trying to get offsets for, and null OffsetAndTimestamp as value

timestampsToSearch

public Map<org.apache.kafka.common.TopicPartition,Long> timestampsToSearch()

requireTimestamps

public boolean requireTimestamps()

equals

public boolean equals(Object o)

Overrides:

equals in class CompletableApplicationEvent<Map<org.apache.kafka.common.TopicPartition,OffsetAndTimestamp>>

hashCode

public int hashCode()

Overrides:

hashCode in class CompletableApplicationEvent<Map<org.apache.kafka.common.TopicPartition,OffsetAndTimestamp>>

toString

public String toString()

Overrides:

toString in class CompletableApplicationEvent<Map<org.apache.kafka.common.TopicPartition,OffsetAndTimestamp>>