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

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

Related Packages

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

Class	Description
ApplicationEvent	This is the abstract definition of the events created by the KafkaConsumer API
ApplicationEvent.Type
ApplicationEventHandler	An event handler that receives application events from the application thread which are then readable from the ApplicationEventProcessor in the network thread.
ApplicationEventProcessor	An EventProcessor that is created and executes in the network thread which processes application events generated by the application thread.
AssignmentChangeApplicationEvent
BackgroundEvent	This is the abstract definition of the events created by the network thread.
BackgroundEvent.Type
BackgroundEventHandler	An event handler that receives background events from the network thread which are then made available to the application thread via the invalid reference BackgroundEventProcessor .
CommitApplicationEvent
CommitOnCloseApplicationEvent
CompletableApplicationEvent<T>	Application event with a result in the form of a future, that can be retrieved within a timeout based on completion.
CompletableBackgroundEvent<T>	Background event with a result in the form of a future, that can be retrieved within a timeout based on completion.
CompletableEvent<T>
ConsumerRebalanceListenerCallbackCompletedEvent	Event that signifies that the application thread has executed the ConsumerRebalanceListener callback.
ConsumerRebalanceListenerCallbackNeededEvent	Event that signifies that the network I/O thread wants to invoke one of the callback methods on the ConsumerRebalanceListener.
ErrorBackgroundEvent
EventProcessor<T>	An EventProcessor is the means by which events produced by thread A are processed by thread B.
EventProcessor.ProcessHandler<T>
FetchCommittedOffsetsApplicationEvent
GroupMetadataUpdateEvent	This event is sent by the consumer's network thread to the application thread so that when the user calls the Consumer.groupMetadata() API, the information is up-to-date.
LeaveOnCloseApplicationEvent
ListOffsetsApplicationEvent	Event for retrieving partition offsets by performing a ListOffsetsRequest.
NewTopicsMetadataUpdateRequestEvent
PollApplicationEvent
ResetPositionsApplicationEvent	Event for resetting offsets for all assigned partitions that require it.
SubscriptionChangeApplicationEvent	Application event indicating that the subscription state has changed, triggered when a user calls the subscribe API.
TopicMetadataApplicationEvent
UnsubscribeApplicationEvent	Application event triggered when a user calls the unsubscribe API.
ValidatePositionsApplicationEvent	Event for validating offsets for all assigned partitions for which a leader change has been detected.