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

Class UnsubscribeApplicationEvent

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.UnsubscribeApplicationEvent

All Implemented Interfaces:

CompletableEvent<Void>

public class UnsubscribeApplicationEvent
extends CompletableApplicationEvent<Void>

Application event triggered when a user calls the unsubscribe API. This will make the consumer release all its assignments and send a heartbeat request to leave the consumer group. This event holds a future that will complete when the invocation of callbacks to release complete and the heartbeat to leave the group is sent out (minimal effort to send the leave group heartbeat, without waiting for any response or considering timeouts).

Nested Class Summary

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

ApplicationEvent.Type

Constructor Summary

Constructors

Constructor	Description
UnsubscribeApplicationEvent()

Method Summary

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

chain, equals, future, get, hashCode, toString, 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

UnsubscribeApplicationEvent

public UnsubscribeApplicationEvent()