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

Class ApplicationEventProcessor

java.lang.Object

org.apache.kafka.clients.consumer.internals.events.EventProcessor<ApplicationEvent>

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

All Implemented Interfaces:

Closeable, AutoCloseable

public class ApplicationEventProcessor
extends EventProcessor<ApplicationEvent>

An EventProcessor that is created and executes in the network thread which processes application events generated by the application thread.

Nested Class Summary

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

EventProcessor.ProcessHandler<T>

Constructor Summary

Constructors

Constructor	Description
ApplicationEventProcessor(org.apache.kafka.common.utils.LogContext logContext, BlockingQueue<ApplicationEvent> applicationEventQueue, RequestManagers requestManagers, ConsumerMetadata metadata)

Method Summary

Modifier and Type	Method	Description
boolean	process()	Process the events—if any—that were produced by the application thread.
void	process(ApplicationEvent event)
static Supplier<ApplicationEventProcessor>	supplier(org.apache.kafka.common.utils.LogContext logContext, ConsumerMetadata metadata, BlockingQueue<ApplicationEvent> applicationEventQueue, Supplier<RequestManagers> requestManagersSupplier)	Creates a Supplier for deferred creation during invocation by ConsumerNetworkThread.

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

close, process

Methods inherited from class java.lang.Object

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

Constructor Details

ApplicationEventProcessor

public ApplicationEventProcessor(org.apache.kafka.common.utils.LogContext logContext,
 BlockingQueue<ApplicationEvent> applicationEventQueue,
 RequestManagers requestManagers,
 ConsumerMetadata metadata)

Method Details

process

public boolean process()

Process the events—if any—that were produced by the application thread. It is possible that when processing an event generates an error. In such cases, the processor will log an exception, but we do not want those errors to be propagated to the caller.

Specified by:

process in class EventProcessor<ApplicationEvent>

process

public void process(ApplicationEvent event)

Specified by:

process in class EventProcessor<ApplicationEvent>

supplier

public static Supplier<ApplicationEventProcessor> supplier(org.apache.kafka.common.utils.LogContext logContext,
 ConsumerMetadata metadata,
 BlockingQueue<ApplicationEvent> applicationEventQueue,
 Supplier<RequestManagers> requestManagersSupplier)

Creates a Supplier for deferred creation during invocation by ConsumerNetworkThread.