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

Class BackgroundEventHandler

java.lang.Object

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

public class BackgroundEventHandler
extends Object

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

.

Constructor Summary

Constructors

Constructor	Description
BackgroundEventHandler(org.apache.kafka.common.utils.LogContext logContext, Queue<BackgroundEvent> backgroundEventQueue)

Method Summary

Modifier and Type	Method	Description
void	add(BackgroundEvent event)	Add a BackgroundEvent to the handler.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BackgroundEventHandler

public BackgroundEventHandler(org.apache.kafka.common.utils.LogContext logContext,
 Queue<BackgroundEvent> backgroundEventQueue)

Method Details

add

public void add(BackgroundEvent event)

Add a BackgroundEvent to the handler.

Parameters:

event - A BackgroundEvent created by the network thread