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

Class CommitApplicationEvent

java.lang.Object

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

org.apache.kafka.clients.consumer.internals.events.CompletableApplicationEvent<Void>

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

All Implemented Interfaces:

CompletableEvent<Void>

public class CommitApplicationEvent
extends CompletableApplicationEvent<Void>

Nested Class Summary

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

ApplicationEvent.Type

Constructor Summary

Constructors

Constructor	Description
CommitApplicationEvent(Map<org.apache.kafka.common.TopicPartition,OffsetAndMetadata> offsets, Optional<Long> retryTimeoutMs)	Create new event to commit offsets.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	hashCode()
Map<org.apache.kafka.common.TopicPartition,OffsetAndMetadata>	offsets()
Optional<Long>	retryTimeoutMs()
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

CommitApplicationEvent

public CommitApplicationEvent(Map<org.apache.kafka.common.TopicPartition,OffsetAndMetadata> offsets,
 Optional<Long> retryTimeoutMs)

Create new event to commit offsets. If timer is present, the request will be retried on retriable errors until the timer expires (sync commit offsets request). If the timer is not present, the request will be sent without waiting for a response of retrying (async commit offsets request).

Method Details

offsets

public Map<org.apache.kafka.common.TopicPartition,OffsetAndMetadata> offsets()

retryTimeoutMs

public Optional<Long> retryTimeoutMs()

equals

public boolean equals(Object o)

Overrides:

equals in class CompletableApplicationEvent<Void>

hashCode

public int hashCode()

Overrides:

hashCode in class CompletableApplicationEvent<Void>

toString

public String toString()

Overrides:

toString in class CompletableApplicationEvent<Void>