...
Application thread: user thread on which all
Consumer
API requests and callback handlers are executed.Network thread: client-internal thread on which network I/O related to heartbeat, coordinator, and rebalance is executed.
Event handler: A communication interface between the application thread and network thread
Application event queue: sends events to the network I/O thread from the application thread
Background event queue: sends events from the network thread to the application thread
- Application event processor:
We will discuss the strategy for handling event results in the following section. In short, for async APIs like commitAsync(), CompletableFuture will be used to notify the completion of the events.
...